tencent cloud

from rocketmq.client import Producer, Message

   # Initialize the producer and set group information. group1
   producer = Producer(groupName)
   # Set the service address
   producer.set_name_server_address(nameserver)
   # Set permissions (role name and key)
   producer.set_session_credentials(
        accessKey,  # Role key
       secretKey,  # Role name
       ''
   )
   # Start the producer
   producer.start()

   # Assemble the message. The topic name can be copied from the Topic tab on the console.   
   msg = Message(topicName)
   # Set keys
   msg.set_keys(TAGS)
   # Set tags
   msg.set_tags(KEYS)
   # Message content
   msg.set_body('This is a new message.')

   # Send synchronous messages
   ret = producer.send_sync(msg)
   print(ret.status, ret.msg_id, ret.offset)
   # Release resources
   producer.shutdown()

import time

   from rocketmq.client import PushConsumer, ConsumeStatus


   # Callback for message processing.
   def callback(msg):
       # Simulate the business.
       print('Received message. messageId: ', msg.id, ' body: ', msg.body)
       # Return `CONSUME_SUCCESS` if the consumption is successful.
       return ConsumeStatus.CONSUME_SUCCESS
       # Return the status of the message upon successful consumption.
       # return ConsumeStatus.RECONSUME_LATER


   # Initialize the consumer and set the consumer group information. 
   consumer = PushConsumer(groupName)
   # Set the service address
   consumer.set_name_server_address(nameserver)
   # Set permissions (role name and key)
   consumer.set_session_credentials(
       accessKey,  # Role key
       secretKey,  # Role name
       ''
   )
   # Subscribe to a topic.
   consumer.subscribe(topicName, callback, TAGS)
   print(' [Consumer] Waiting for messages.')
   # Start the consumer.
   consumer.start()

   while True:
       time.sleep(3600)
   # Release resources
   consumer.shutdown()