tencent cloud

from rocketmq.client import Producer, Message

   # Initialize the producer and set the producer group information. Be sure to use the full name of the group, such as `rocketmq-xxx|namespace_python%group1`.
   producer = Producer(groupName)
   # Set the service address
   producer.set_name_server_address(nameserver)
   # Set permissions (role name and token)
   producer.set_session_credentials(
        accessKey,  # Role token
       secretKey,  # Role name
       ''
   )
   # Start the producer
   producer.start()

   # Assemble messages. The topic name can be copied on the **Topic** page in 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 messages in sync mode
   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


   # Message processing callback
   def callback(msg):
       # Simulate the business processing logic
       print('Received message. messageId: ', msg.id, ' body: ', msg.body)
       # Return CONSUME_SUCCESS if the consumption is successful
       return ConsumeStatus.CONSUME_SUCCESS
       # Return the consumption status if the consumption is successful
       # 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 token)
   consumer.set_session_credentials(
       accessKey,	 # Role token
       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()