使用apache-beam的scd-2实现python

问题描述

我想基于某些键将目标表中的记录与源表中的每日传入记录进行比较,然后决定是否将更新或插入新条目到目标表中。 我相信,这可能在使用合并的大查询中实现,但我希望使用Beam来实现,并在Google云端数据流上运行。

这里要注意的关键是我想比较JSON格式的记录。 任何建议都会有所帮助。

解决方法

暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!

如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@)