我是python新手。我试图在python shell中使用regex创建一个列表。 在列表中,我有3个值topic-1,topic-2,topic-3。我正在创建一个具有topic的使用者对象,topic应该包含3个值[topic1,topic2,topic3]。所以每当我想指出主题1,主题2,主题3中的任何一个,它都应该从正确的主题中得到信息。 我遵循下面的代码,但它给出了一个问题
import pulsar
import re
client = pulsar.Client('pulsar://localhost:6650')
topic='my-topic'
topic=['topic-1', 'topic-2', 'topic-3']
topic=re.compile('topic-.*')
print(topic)
<_sre.SRE_Pattern object at 0x7f13314e7210>
consumer = client.subscribe(topic, "my-subscription")
2019-04-26 07:05:02.956 INFO ConnectionPool:72 | Created connection for
pulsar://localhost:6650
2019-04-26 07:05:02.957 INFO ClientConnection:300 | [127.0.0.1:55874 ->
127.0.0.1:6650] Connected to broker
在这里,我可以创建consumer对象,但它没有像[topic-1,topic-2,topic-3]那样创建正确的值 因为下一步我无法收到消息。 什么是语法问题
我没发现你的语法有什么明显的错误。你确定你的命名空间中有这些主题吗?尝试使用pulsar的命令行工具,例如:
pulsar管理租户列表
pulsar管理名称空间列表<&燃气轮机
pulsar管理主题列表租户/集群/命名空间
有关更多选项,请参见此处:https://pulsar.apache.org/docs/latest/reference/CliTools/
相关问题 更多 >
编程相关推荐