NiFi数据插入s3子目录

施拉德

我有一个流程,要从数据库中提取数据,将Avro转换为CSV格式,然后将CSV推入带有子文件夹的s3存储桶中。我的S3结构如下:

在此处输入图片说明

如您在上面的屏幕截图中所见,我的文件进入一个空白文件夹(以红色突出显示),而不是进入一个名为“ Thermal”的子文件夹。请查看我的PutS3Object设置:

在此处输入图片说明

我希望我的文件进入的最终s3路径是:export-csv-vehicle-telemetry / vin11 / Thermal

我应该在处理器中更改哪些设置,以便文件直接进入“ Thermal”文件夹中?

阿卡什·古普塔(Akash Gupta)

将存储桶名称用作:export-csv-vehicle-telemetry / vin15 / Thermal,而不是export-csv-vehicle-telemetry / vin15 / Thermal /

指定存储桶名称时,不需要在末尾添加额外的斜杠。

顺便说一句,您的图像显示的是vin11目录而不是vin15。检查是否正确。

本文收集自互联网,转载请注明来源。

如有侵权,请联系 [email protected] 删除。

编辑于
0

我来说两句

0 条评论
登录 后参与评论

相关文章

从PySpark中的s3子目录读取数据

如何从存储桶根目录重定向到AWS S3中的子目录?

授予访问权限以读取Amazon S3存储桶中的子目录

如何创建s3存储桶子目录(无服务器)?

通配符子域指向相应的S3 / CloudFront子目录

亚马逊s3 aws url路径子目录存储桶

在 AWS S3 上创建过时的子目录的简单方法

也可以使用Jenkins S3插件复制子目录

从子目录递归读取文件,并使用s3或本地文件系统中的spark

s3的spring-integration-aws是否可以复制存储桶子目录?

如何使用aws s3 cp复制根目录中的所有对象,而不复制子目录?

从带有boto3和Python 3.7的AWS S3的特定“子目录”下载多个文件

如何将子目录路径传递给GunDB S3存储驱动程序,以便可以与非Gun数据共享同一S3存储桶?

使用Python获取AWS S3子目录中每个文件夹的最后修改日期

Amazon Web Services(AWS)S3 Java创建一个子目录(对象)

重定向/重写(在Nginx中)对子目录的请求到S3兼容存储桶

AWS Lambda将列出文件版本控制中的S3存储桶对象和子目录

将CSV文件从公共Git子目录复制到S3存储桶

如果从S3存储桶根目录中删除了图像,如何从子目录中删除相应的缩略图?

访问包子目录中的数据

创建子目录并在其中插入文件

根据过滤的数据移动目录和子目录

Python3如何导入导入子目录文件的子目录文件?

htaccess的子目录

Golang子目录

检查子目录

排除子目录

AWS S3+Cloudfront 静态网站子目录不起作用

Sonata Media Bundle + AWS S3-指定子目录?