如何从数据流管道中的PubSub子目录中读取

Question

我正在通过MQTT向Google IoT核心发送消息
My Iot注册表与3个PubSub主题关联，每个主题都有几个子目录。

我的消息被转发到PubSub，然后由数据流管道处理
在我的管道中，我阅读了Pub/Sub，如下所示：

common = (
pipeline
| 'Get common on pub/sub' >> beam.io.ReadFromPubSub(
topic='projects/project-id/topics/topics-id',
with_attributes=True)
)

但我希望能够阅读我的公共子主题子目录，这可能吗
我已经尝试过这样添加它：

topic='projects/project-id/topics/topics-id/sub-directory'

不成功

Answer 1

您可以发布到其他子目录主题，并有单独的订阅来读取这些主题。从发布遥测事件的文档到其他云发布/子主题：

设备可以将数据发布到其他云发布/子主题。默认情况下，发布到/devices/DEVICE_ID/events的MQTT消息被转发到相应注册表的默认遥测主题。您可以在MQTT主题中指定一个子文件夹，以将数据转发到其他Cloud Pub/Sub主题。子文件夹是/devices/DEVICE_ID/events.之后的子主题

上面链接的文档提供了有关如何设置的更多详细信息，以及消息将和不会发布到子目录主题的情况。