python怎么安装acl包

搜索本产品内容

查询

文档中心 >消息队列 CKafka >SDK 文档 >Python SDK >公网 SASL_SSL 方式接入

公网 SASL_SSL 方式接入

最近更新时间：2021-12-28 09:54:00

*** 作场景

前提条件

*** 作步骤

步骤1：准备工作

步骤2：生产消息

步骤3：消费消息

*** 作场景

该任务以 Python 客户端为例，指导您使用公网 SASL_SSL 方式接入消息队列 CKafka 并收发消息。

前提条件

安装 Python

安装 pip

配置 ACL 策略

下载 Demo

下载 SASL_SSL 证书

*** 作步骤

步骤1：准备工作

创建接入点。

在 实例列表 页面，单击目标实例 ID，进入实例详情页。

在 基本信息 >接入方式 中，单击添加路由策略，在打开窗口中选择：路由类型：公网域名接入,接入方式：SASL_SSL。



创建角色。

在用户管理页面新建角色，设置密码。



创建 Topic。

在控制台 topic 管理页面新建 Topic（参见 创建 Topic）。

添加 Python 依赖库。

执行以下命令安装：

pip install kafka-python

步骤2：生产消息

修改生产消息程序 producer.py 中配置参数。

producer = KafkaProducer(

bootstrap_servers = ['xx.xx.xx.xx:port'],

api_version = (1, 1),

#

# SASL_SSL 公网接入

#

security_protocol = "SASL_SSL",

sasl_mechanism = "PLAIN",

sasl_plain_username = "instanceId#username",

sasl_plain_password = "password",

ssl_cafile = "CARoot.pem",

ssl_check_hostname = False,

)

message = "Hello World! Hello Ckafka!"

msg = json.dumps(message).encode()

producer.send('topic_name', value = msg)

print("produce message " + message + " success.")

producer.close()

参数

描述

bootstrap_servers

接入网络，在控制台的实例详情页面接入方式模块的网络列复制。



sasl_plain_username

用户名，格式为 实例 ID + # + 用户名。实例 ID 在 CKafka 控制台 的实例详情页面的基本信息获取，用户在用户管理创建用户时设置。

sasl_plain_password

用户密码，在 CKafka 控制台实例详情页面的用户管理创建用户时设置。

topic_name

Topic 名称，您可以在控制台上 topic管理页面复制。



CARoot.pem

采用 SASL_SSL 方式接入时，所需的证书路径。

编译并运行 producer.py。

查看运行结果。



在 CKafka 控制台 的 topic管理页面，选择对应的 Topic ， 单击更多 >消息查询，查看刚刚发送的消息。



步骤3：消费消息

修改消费消息程序 consumer.py 中配置参数。

consumer = KafkaConsumer(

'topic_name',

group_id = "group_id",

bootstrap_servers = ['xx.xx.xx.xx:port'],

api_version = (1,1),

#

# SASL_SSL 公网接入

#

security_protocol = "SASL_SSL",

sasl_mechanism = 'PLAIN',

sasl_plain_username = "instanceId#username",

sasl_plain_password = "password",

ssl_cafile = "CARoot.pem",

ssl_check_hostname = False,

)

for message in consumer:

print ("Topic:[%s] Partition:[%d] Offset:[%d] Value:[%s]" %

(message.topic, message.partition, message.offset, message.value))

参数

描述

bootstrap_servers

接入网络，在控制台的实例详情页面接入方式模块的网络列复制。



group_id

消费者的组 ID，根据业务需求自定义。

sasl_plain_username

用户名，格式为 实例 ID + # + 用户名。实例 ID 在CKafka 控制台的实例详情页面的基本信息获取，用户在用户管理创建用户时设置。

sasl_plain_password

用户名密码，在 CKafka 控制台实例详情页面的用户管理创建用户时设置

topic_name

Topic 名称，您可以在控制台上 topic管理页面复制。



CARoot.pem

采用 SASL_SSL 方式接入时，所需的证书路径。

编译并运行 consumer.py。

查看运行结果。



在 CKafka 控制台 的 Consumer Group 页面，选择对应的消费组名称，在主题名称输入 Topic 名称，单击查询详情，查看消费详情。



上一篇: 公网 SASL_PLAINTEXT 方式接入下一篇: VPC 网络接入

文档内容是否对您有帮助？

有帮助没帮助

如果遇到产品相关问题，您可咨询 在线客服 寻求帮助。

消息队列 CKafka 相关文档

API 概览

创建主题

签名方法

获取实例列表

删除主题白名单

增加主题白名单

错误返回结果

产品概述

获取主题属性

点击搜索腾讯云文档

取消

清除查询

Python在安装的时候，您应当确保Python配备了pip.

使用pip来安装各种模块和包，就可以实现自动化，自动检查依赖，自动安装。

否则，就只能下载安装包或者一个个手动安装。

依赖库：

//使用apt 安装即可

1.gcc, make, zlib1g-dev（压缩／解压缩库）

安装过程需要的库。

2.libbz2-dev

bz2支持库，若在编译安装python前没有安装，将无法通过pip install 安装提供bz2格式的第三方库，会出现unsupported archive format: .tar.bz2的错误，例如爬虫库Scrapy依赖的Twisted。

3.libsqlite3-dev

sqlite3支持库，若在编译安装python前没有安装，则python中会缺失sqlite3模块，当引入sqlite3或使用依赖sqllite3的第三方库(例如Scrapy)时，会出现ImportError: No modul named _sqllite3的错误。

//以上为编译安装前需要安装的库，可能不够全面，会不断补充。

4.其他：安装第三方库需要的库

python3-dev, libxml2-dev, libxslt1, libffi-dev, libssl-dev等，在安装第三方库会有具体说明，不做过多解释。

安装：

//通过wget获取压缩包，这里选择3.6.1版

wget https://www.python.org/ftp/python/3.6.1/Python-3.6.1.tar.xz

//解压

tar xJf Python-3.6.1.tar.xz

cd Python-3.6.1

./configure

make

/*这步如果需要sudo，请使用sudo -H命令，即sudo -H make install，避免pip等模块安装失败。

错误示例(pip安装失败)：The directory '/home/ls/.cache/pip' or its parent directory is not owned by the current user and caching wheels has been disabled. check the permissions and owner of that directory. If executing pip with sudo, you may want sudo's -H flag.

*/

make install

---