tencent cloud

from rocketmq.client import Producer, Message

   # 初始化生产者，并设置生产组信息，group1
   producer = Producer(groupName)
   # 设置服务地址
   producer.set_name_server_address(nameserver)
   # 设置权限（角色名和密钥）
   producer.set_session_credentials(
        accessKey,  # 角色密钥
       secretKey,  # 角色名称
       ''
   )
   # 启动生产者
   producer.start()

   # 组装消息   topic名称，在控制台 topic 页面复制。   
   msg = Message(topicName)
   # 设置keys
   msg.set_keys(TAGS)
   # 设置tags
   msg.set_tags(KEYS)
   # 消息内容
   msg.set_body('This is a new message.')

   # 发送同步消息
   ret = producer.send_sync(msg)
   print(ret.status, ret.msg_id, ret.offset)
   # 资源释放
   producer.shutdown()

import time

   from rocketmq.client import PushConsumer, ConsumeStatus


   # 消息处理回调
   def callback(msg):
       # 模拟业务
       print('Received message. messageId: ', msg.id, ' body: ', msg.body)
       # 消费成功回复CONSUME_SUCCESS
       return ConsumeStatus.CONSUME_SUCCESS
       # 消费成功回复消息状态
       # return ConsumeStatus.RECONSUME_LATER


   # 初始化消费者，并设置消费者组信息 
   consumer = PushConsumer(groupName)
   # 设置服务地址
   consumer.set_name_server_address(nameserver)
   # 设置权限（角色名和密钥）
   consumer.set_session_credentials(
       accessKey,	 # 角色密钥
       secretKey,   # 角色名称
       ''
   )
   # 订阅topic
   consumer.subscribe(topicName, callback, TAGS)
   print(' [Consumer] Waiting for messages.')
   # 启动消费者
   consumer.start()

   while True:
       time.sleep(3600)
   # 资源释放
   consumer.shutdown()