如何解决如何使用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 举报,一经查实,本站将立刻删除。