如何使用 ksql 将 String 类型转换为结构数组
我在 Kafka 中有一个主题,其架构如下:
Name Type
ID STRING
ORDER_STATUS INTEGER
ORDER_ITEM_JSON STRING
ORDER_ITEM_JSON 本身是一个项目字符串:
"ORDER_ITEM_JSON":"[{\"item_id\":\"943\",\"category_id_fk\":\"42\",\"item_count\":\"1\",\"item_price\":55900,\"item_price_without_discount\":55900},{\"item_id\":\"1235\",\"category_id_fk\":\"42\",\"item_count\":\"1\",\"item_price\":25500,\"item_price_without_discount\":25500},{\"item_id\":\"1250\",\"category_id_fk\":\"42\",\"item_count\":\"1\",\"item_price\":37500,\"item_price_without_discount\":37500}]"
如何将此字符串字段转换为 ksql 中的结构数组?
如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。
绑定邮箱获取回复消息
由于您还没有绑定你的真实邮箱,如果其他用户或者作者回复了您的评论,将不能在第一时间通知您!
发布评论
评论(1)
我认为您应该使用已定义的 ARRAY 重新创建流,而不是事后进行强制转换。
处理嵌套 json
I think you should re-create the stream with
ARRAY<STRUCT
already defined rather than cast afterwards.Examples on dealing with nested json