python如何在线加包

Python2.7:

sudo pip install <包的名字>

Python 3+:

sudo pip3 install <包的名字>

比如在线增加多个包：

sudo pip3 install tensorflow pandas

搜索本产品内容

查询

文档中心 >消息队列 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 运行环境在查找模块时是对 sys.path 列表进行遍历，如果我们想在运行环境中添加自定义的模块，主要有以下三种方法：

1. 在sys.path列表中添加新的路径（只能对执行了 sys.path.append 命令的当前 Python 运行环境起作用，对其他运行环境不起作用，也即“一次性”的）。

>>>import sys

>>>sys.path

>>>sys.path.append('/home/xxx/yyy') #目录/home/xxx/yyy包含你所需要的包或模块

设置 PYTHONPATH 环境变量（永久性添加）：

2. 将包或模块复制到 sys.path 列表中的目录（通过 sys.path 查看）里（如 /home/test/lib/python2.7/site-packages/ 目录）。

3. 最简单的办法是用 .pth 文件来实现。Python 在遍历已有的库文件目录（sys.path中指定）过程中，如果见到一个 .pth 文件，就会将该文件中所记录的路径加入到 sys.path 设置中，这样 .pth 文件说指明的库也就可以被 Python 运行环境找到。

$cd /home/test/lib/python2.7/site-packages/

$touch test.pth

$vim test.pth

$添加一行包或模块所在的目录(如：/home/test/somePackage/)

则test.pth文件内容为：

/home/test/somePackage/

---