微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

托管API并将Json数据推送到S3,同时将其转换为Avro

如何解决托管API并将Json数据推送到S3,同时将其转换为Avro

我想使用HandleHTTP处理器在Nifi中托管API。我想传递一些虚拟json数据。我想将JSON数据转换为avro,然后将其推送到S3存储桶。

当json数据从HandleHTTPResponse转换为ConvertRecord时,出现以下错误(正在转换json-> Avro),因此数据进入了该失败管道。

有人可以帮我吗?

Hosting an API and pushing Json data to S3 while converting it to Avro.

解决方法

这意味着在ConvertRecord中,您有一个配置为“模式名称”的“模式访问策略”的记录读取器,并且您将“模式名称”属性设置为默认值“ $ {schema.name}”,但是您的流文件没有schema.name作为属性。

如果知道所有时间都相同,则可以将“模式名称”更改为模式名称的硬编码值,也可以将schema.name作为请求的标头发送给HandleHttpRequest,然后将schema.name用作属性。

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。