是否可以使用在pub子模拟器中创建的主题作为数据源，并在apache光束python中直接运行？

我已经设置了环境变量（也在脚本中）：

set PUBSUB_EMULATOR_HOST=localhost:8085
set PUBSUB_PROJECT_ID=<proj_id>

它似乎没有连接到它，因为即使我将模拟器主机设置为其他任何东西，它也会给出相同的错误，如果没有设置，它会查找凭据。

尝试使用主题和订阅ID（拉取）阅读消息。

使用输入主题：

文件"lib\site-包\apache_beam\runner\Direct\transform_evaluator.py"，第646行，get_subscriptiontopic_name=sub_client.topic_path（项目，short_topic_name）属性错误：'SubscriberClient'对象没有属性'topic_path'

使用订阅ID（拉取）：

lib\site-包\apache_beam\runner\Direct\transform_evaluator.py"，第694行，在_read_from_pubsubsub_client.api.transport.channel。关闭（）属性错误：'SubscriberClient'对象没有属性'传输'

java，文档（setPubsubRootUrl（String））中提到了模拟器的使用，但找不到任何Python。