面临问题,同时在 re.compile python 正则表达式中创建列表



我正在尝试在Python shell中使用正则表达式创建一个列表。在列表中,我有 3 个值主题-1、主题-2、主题-3。我正在创建一个具有主题的消费者对象,主题应包含 3 个值 [主题 1、主题 2、主题 3]。所以每当我想指出主题 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

在这里,我能够创建消费者对象,但它不是像[topic-1, topic-2, topic-3]那样具有正确值的创建因为在下一步中我无法收到消息。语法问题是什么?

我在你的语法中找不到任何明显的错误。是否确定命名空间中有这些主题?尝试使用 Pulsar 的命令行工具,例如:

脉冲星管理员租户列表

脉冲星管理员命名空间列表<>

Pulsar 管理员主题列表租户/集群/命名空间

有关更多选项,请参阅此处:https://pulsar.apache.org/docs/latest/reference/CliTools/

最新更新