使用 Dataflow SQL,我想读取 Pub/Sub 主题,丰富消息并将消息写入 Pub/Sub 主题。
哪个 Dataflow SQL 查询将创建我想要的输出消息?
Pub/Sub input消息:{“event_timestamp”:1619784049000,“设备”:{“ID”:“some_id”}}
所需的发布/订阅output消息:{“event_timestamp”:1619784049000,“设备”:{“ID”:“some_id”,“NAME”:“some_name”}}
我得到的是: {"event_timestamp":1619784049000, "device":{"ID":"some_id"}, "NAME":"some_name" }
但我需要名字inside“设备”属性。
SELECT message_table.device as device, devices.name as NAME
FROM pubsub.topic.project_id.`topic` as message_table
JOIN bigquery.table.project_id.dataflow_sql_dataset.devices as devices
ON devices.device_id = message_table.device.id
不幸的是,Dataflow SQL 目前不支持 STRUCT/Sub 查询,但我们正在努力解决它。由于存在一些 Apache Beam 依赖项阻碍其进展(嵌套行支持 https://issues.apache.org/jira/browse/BEAM-9378, 升级方解石 https://issues.apache.org/jira/browse/BEAM-9379),我们目前无法提供预计到达时间,但您可以关注其进展情况问题跟踪器 https://issuetracker.google.com/190024082.
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)