| 12345678910111213141516171819202122232425 |
- from mq_http_sdk.mq_client import *
- def get_consumer(topic_name, group_id):
- # 初始化client。
- mq_client = MQClient(
- # 设置HTTP协议客户端接入点，进入云消息队列 RocketMQ 版控制台实例详情页面的接入点区域查看。
- "http://1894469520484605.mqrest.cn-qingdao-public.aliyuncs.com",
- # AccessKey ID，阿里云身份验证标识。获取方式，请参见创建AccessKey。
- "LTAI4G7puhXtLyHzHQpD6H7A",
- # AccessKey Secret，阿里云身份验证密钥。获取方式，请参见创建AccessKey。
- "nEbq3xWNQd1qLpdy2u71qFweHkZjSG",
- )
- # 消息所属的Topic，在云消息队列 RocketMQ 版控制台创建。
- # topic_name = "${TOPIC}"
- topic_name = str(topic_name)
- # 您在云消息队列 RocketMQ 版控制台创建的Group ID。
- # group_id = "${GROUP_ID}"
- group_id = str(group_id)
- # Topic所属的实例ID，在云消息队列 RocketMQ 版控制台创建。
- # 若实例有命名空间，则实例ID必须传入；若实例无命名空间，则实例ID传入空字符串。实例的命名空间可以在云消息队列 RocketMQ 版控制台的实例详情页面查看。
- instance_id = "MQ_INST_1894469520484605_BXhXuzkZ"
- consumer = mq_client.get_consumer(instance_id, topic_name, group_id)
- return consumer
|
