如何使用Dataflow发布具有自定义属性的消息

问题描述

大师。

我试图在google上搜索所有内容，但似乎找不到任何资源来发布带有自定义属性的消息到发布/订阅主题。

目标：

• 一个带有2个订阅的主题
• 每个订阅都有一个用于特定值的订阅过滤器：
  • SubscriptionA-attribute.table =“ Table1”
  • SubscriptionB-attribute.table =“ Table2”

已经完成：

• 将有特定的数据流触发器监视每个订阅
• 已应用于每个订阅的过滤器，邮件被路由到特定的订阅。

挑战：

• 如何将具有自定义属性的简单消息写到Pub / Sub主题，例如：
  • APPLICATION_A-在先前执行之后，发送属性“ table”的值为“ Table1”的发布/订阅消息
  • APPLICATION_B-先前执行后，发送属性“ table”的值为“ Table2”的发布/订阅消息

下一步：

• 也许有人能指出我实现这一目标的正确方向吗？还是某种指南？
• 由于找到的大多数资源都只专注于发送消息，所以属性本身呢？通过Dataflow / Beam写入发布/订阅主题时，是否可以添加自定义属性？

解决方法

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

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

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