tencent cloud

All product documents
TDMQ for RabbitMQ
DocumentationTDMQ for RabbitMQSDK DocumentationSDK for Python
SDK for Python
Download PDF
Last updated: 2024-01-03 11:45:32
SDK for Python
Last updated: 2024-01-03 11:45:32
Download PDF

Overview

This document describes how to use open-source SDK to send and receive messages using the SDK for Python as an example and helps you better understand the message sending and receiving processes.

Prerequisites

You have created the required resources.
You have installed Python
You have installed pip
You have downloaded the demo

Directions

Step 1. Add dependencies

1. RabbitMQ officially recommends Pika. First, you need to install Pika in the client environment.
python -m pip install pika --upgrade
2. Import Pika when creating the client.
import pika

Step 2. Produce messages

Create, compile, and run the message producing program messageProducer.py.
import pika

# Use the username and password to create a login credential object
credentials = pika.PlainCredentials('rolename', 'eyJr***')
# Create a connection
connection = pika.BlockingConnection(pika.ConnectionParameters(
    host='amqp-xx.rabbitmq.x.com', port=5672, virtual_host='amqp-xxx|Vhostname', credentials=credentials))
# Establish a channel
channel = connection.channel()
# Declare the exchange
channel.exchange_declare(exchange='direct_exchange', exchange_type="direct")

routingKeys = ['aaa.bbb.ccc', 'aaa.bbb.ddd', 'aaa.ccc.zzz', "xxx.yyy.zzz"]

for routingKey in routingKeys:
    # Send a message to the specified exchange
    # If you send a message without specifying the exchange, you need to specify the message queue. If the exchange is specified, the `routing_key` parameter indicates the routing key; otherwise, it indicates the message queue name
    channel.basic_publish(exchange='direct_exchange',
                          routing_key=routingKey,
                          body=(routingKey + 'This is a new direct message.').encode(),
                          properties=pika.BasicProperties(
                              delivery_mode=2,  # Set message persistence
                          ))
    print('send success msg to rabbitmq')
connection.close()
Parameter
Description
rolename
Role name, which can be copied on the Role Management page.
eyJr***
Role key, which can be copied in the Key column on the Role Management page.
img


host
Cluster access address, which can be obtained from Access Address in the Operation column on the Cluster page.
img


port
Cluster access port, which can be obtained from Access Address in the Operation column on the Cluster page.
virtual_host
Vhost name in the format of "cluster ID + | + vhost name", which can be copied on the Vhost page in the console.
img


direct_exchange
Exchange name, which can be obtained from the exchange list in the console.
routingKeys
Message routing rule, which can be obtained in the Binding Key column in the binding list in the console.
img



Step 3. Consume messages

Create, compile, and run the message consuming program messageConsumer.py.
import os
import pika
import sys


def main():
    # Use the username and password to create a login credential object
    credentials = pika.PlainCredentials('rolename', 'eyJr***')
    # Create a connection
    connection = pika.BlockingConnection(pika.ConnectionParameters(
        host='amqp-xx.rabbitmq.x.com', port=5672, virtual_host='amqp-xxx|Vhostname', credentials=credentials))
    # Establish a channel
    channel = connection.channel()
    # Declare the message queue
    channel.queue_declare(queue='route_queue1', exclusive=True, durable=True)
    # Bind the message queue to the exchange and specify the routing key
    routing_keys = ['aaa.bbb.ccc', 'aaa.bbb.ddd']
    for routingKey in routing_keys:
        channel.queue_bind(exchange='direct_exchange', queue="route_queue1", routing_key=routingKey)
    # Set that only one unacknowledged message can be received
    channel.basic_qos(prefetch_count=1)

    # Message consumption logic
    def callback(ch, method, properties, body):
        print(" [Consumer1(Direct 'aaa.bbb.ccc'/'aaa.bbb.ddd')] Received (%r)" % body)
        # Manually return the ACK
        ch.basic_ack(delivery_tag=method.delivery_tag)

    # Create a consumer to consume messages in the message queue
    channel.basic_consume(queue='route_queue1',
                          on_message_callback=callback,
                          auto_ack=False)  # Set to manual acknowledgment

    print(" [Consumer1(Direct 'aaa.bbb.ccc'/'aaa.bbb.ddd')] Waiting for messages. To exit press CTRL+C")
    channel.start_consuming()


if __name__ == '__main__':
    try:
        main()
    except KeyboardInterrupt:
        print('Interrupted')
        try:
            sys.exit(0)
        except SystemExit:
            os._exit(0)
Parameter
Description
rolename
Role name, which can be copied on the Role Management page.
eyJr***
Role key, which can be copied in the Key column on the Role Management page.
img


host
Cluster access address, which can be obtained from Access Address in the Operation column on the Cluster page.
img


port
Cluster access port, which can be obtained from Access Address in the Operation column on the Cluster page.
virtual_host
Vhost name in the format of "cluster ID + | + vhost name", which can be copied on the Vhost page in the console.
img


direct_exchange
Exchange name, which can be obtained from the exchange list in the console.
route_queue1
Queue name, which can be obtained from the queue list in the console.
routingKey
Message routing rule, which can be obtained in the Binding Key column in the binding list in the console.
img



Step 4. View messages

To check whether messages are sent to TDMQ for RabbitMQ successfully, view the connected consumer status on the Cluster > Queue page in the console.

img


Note:
For the complete sample code and other use cases, see Demo or RabbitMQ Tutorials.

Was this page helpful?
You can also Contact Sales or Submit a Ticket for help.
Yes
No

Feedback

Contact Us

Contact our sales team or business advisors to help your business.

Contact Us
Technical Support

Open a ticket if you're looking for further assistance. Our Ticket is 7x24 avaliable.

Submit a Ticket
7x24 Phone Support
Hong Kong, China
+852 800 906 020 (Toll Free)
United States
+1 844 606 0804 (Toll Free)
United Kingdom
+44 808 196 4551 (Toll Free)
Canada
+1 888 605 7930 (Toll Free)
Australia
+61 1300 986 386 (Toll Free)
EdgeOne hotline
+852 300 80699
More local hotlines coming soon