要在Apache NiFi中使用PutGCSObject将对象放置在自定义目录下,您可以使用PutGCSObject和UpdateAttribute处理器的组合。
以下是一个解决方案的示例:
${filename:replace('YOUR_SOURCE_DIRECTORY/','')}
。这将删除原始目录路径并将文件名保留下来。${filename}
,这将使用我们在UpdateAttribute中创建的新文件名。以下是示例NiFi流程:
[GetFile] -> [UpdateAttribute] -> [PutGCSObject]
在UpdateAttribute处理器的属性列表中添加以下属性:
${filename:replace('YOUR_SOURCE_DIRECTORY/','')}
在PutGCSObject处理器的属性列表中添加以下属性:
${filename}
这将确保将文件放置在自定义目录中,并且在Google Cloud Storage中使用正确的文件名。
请注意,您需要根据自己的需求和环境调整上述示例中的属性和值。