tencent cloud

pip install --upgrade tencentcloud-sdk-python

 # Authentication information
 cred = credential.Credential(SECRET_ID, SECRET_KEY)
 httpProfile = HttpProfile()
 httpProfile.endpoint = ENDPOINT

 clientProfile = ClientProfile()
 clientProfile.httpProfile = httpProfile
 # Create the TDMQ client
 client = tdmq_client.TdmqClient(cred, REGION, clientProfile)

 # Message sending request parameters
 req = models.SendMessagesRequest()
 params = {
     # Authorized role token
     "StringToken": token,
     # Topic name in the format of cluster (tenant) ID/namespace/topic name
     "Topic": topicName,
     # Message content
     "Payload": "this is a new message.",
     # Authorized role name
     "ProducerName": userName,
     # Sending timeout period
     "SendTimeout": 3000,
 }
 req.from_json_string(json.dumps(params))

 # Send the message
 resp = client.SendMessages(req)

 # Message receiving request parameters
 req = models.ReceiveMessageRequest()
 params = {
     # Topic name in the format of cluster (tenant) ID/namespace/topic name
     "Topic": topicName,
     # Subscription name
     "SubscriptionName": subName,
     # Messages received by the consumer will first be stored in the `receiverQueueSize` queue to tune the message receiving rate.
     "ReceiverQueueSize": 10,
     # It is used to determine the position where the consumer initially receives messages. Valid values: `Earliest`, `Latest`.
     "SubInitialPosition": "Latest"
 }
 req.from_json_string(json.dumps(params))

 # Receive the message
 resp = client.ReceiveMessage(req)

 # Message acknowledging request parameters
 req = models.AcknowledgeMessageRequest()
 params = {
     # ID of the message to be acknowledged
     "MessageId": messageId,
     # Topic name in the format of cluster (tenant) ID/namespace/topic name
     "AckTopic": topicName,
     # Subscription name
     "SubName": subName
 }
 req.from_json_string(json.dumps(params))

 # Acknowledge the message
 resp = client.AcknowledgeMessage(req)