automatic_crawler/application/common/messageQueue/consumer.py

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