设置Python客户端
要在Pulsar中设置Python客户端库,请完成以下步骤。
第一步:安装Python客户端库
使用 pip 安装最新版本:
pip install 'pulsar-client==3.5.0'
您可以安装与客户端库一起的可选组件:
# avro serialization
pip install 'pulsar-client[avro]==3.5.0'
# functions runtime
pip install 'pulsar-client[functions]==3.5.0'
# all optional components
pip install 'pulsar-client[all]==3.5.0'
可以通过PyPi安装以下Python版本:
平台 | 支持的Python版本 |
---|---|
macOS (>= 11.0) | 3.7, 3.8, 3.9 和 3.10 |
Linux(包括Alpine Linux) | 3.7, 3.8, 3.9 和 3.10 |
步骤2:连接到Pulsar集群
要使用客户端库连接到Pulsar,您需要指定一个Pulsar协议 URL。
您可以将Pulsar协议URL分配给特定的集群并使用pulsar
方案。以下是一个使用默认端口6650
的localhost
示例:
pulsar://localhost:6650
如果您有多个代理,请用逗号分隔 IP:port
:
pulsar://localhost:6550,localhost:6651,localhost:6652
如果您使用mTLS认证,请在方案中添加+ssl
:
pulsar+ssl://pulsar.us-west.example.com:6651