小编Sam*_*mmy的帖子

在Apache NiFi中,使用FetchS3Object从S3存储桶读取,我发现它可以读取存储桶中的所有对象并添加它们.可能吗:

1. 要将处理器配置为只读取现在添加的对象,而不是已经存在的对象？
2. 如何让它读取存储桶中的特定文件夹？

NiFi看起来很棒,只是缺少他们的文档中至少流行的处理器的例子.

我正在尝试使用Jolt转换非常简单,但努力让它发挥作用.

如果我有一个输入,如:

{
    "id": "54436001"
}

我希望输出为:

{
  "mediaId" : "54436001",
  "events" : {
    "mediaId" : "54436001"
  }
}

这是将值复制到两个不同的属性.我很想尝试使用这样的规格来工作,但很明显它并不是因为重复的密钥.

[
  {
    "operation": "shift",
    "spec": {
      "id": "mediaId",
      "id": "events.mediaId"
    }
  }
]

这可能与Jolf转换有关吗？