Greendeck RabbitMQ包
greendeck-rabbitmq的Python项目详细描述
gd rabbitmq
现在这个包只供 https://pypi.org/project/greendeck-rabbitmq/ 这里有些参数的默认值是 如何构建pip包 在父目录中 更新您的软件包 参考资料 欢迎加入QQ群-->： 979659372
greendeck's内部使用。这将有助于用rabbitmq发布和使用消息
从PIP安装
pip install greendeck-rabbitmq如何使用？
导入库
importgreendeck_rabbitmq
导入{
fromgreendeck_rabbitmqimportRabbitMQ
初始化
RabbitMQ客户端连接fromgreendeck_rabbitmqimportRabbitMQ# declare variablesRMQ_HOST=<YOUR_RMQ_HOST>RMQ_PORT=<YOUR_RMQ_PORT>RMQ_VHOST=<YOUR_RMQ_VHOST>username=<YOUR_USERNAME>password=<YOUR_PASSWORD>```HeredefaultvaluesareRMQ_PORT=5678,RMQ_VHOST='\', username=Null, password=Null```rabbitmq_client=RabbitMQ(RMQ_HOST,RMQ_PORT,RMQ_VHOST,username,password)
关闭
RabbitMQ客户端连接rabbitmq_client.rabbitmq_close_connection()
检查rabbitmq队列的大小
queue="test_library"print(rabbitmq_client.size(queue))
检查队列大小是否为空
queue="test_library"print(rabbitmq_client.is_empty(queue))
使用队列中的所有消息
queue="test_library"rabbitmq_client.rabbitmq_get_all(queue)
单一消息生产者
message="hello world"queue="test_library"routing_key="test_library"exchange=''delivery_mode=2mode="single"```defaultvaluesareexchange='',delivery_mode=2,mode="single"``````availablemodesare'single'&'multi'andin'multi'modeitexpectsmessageaslistofmessagesrabbitmq_client.rabbitmq_publisher(message,queue,routing_key,exchange,delivery_mode,mode)rabbitmq_client.rabbitmq_close_connection()
多消息生产者
message=["hello world"]*100#list of messagesqueue="test_library"routing_key="test_library"exchange=''delivery_mode=2mode="multi"rabbitmq_client.rabbitmq_publisher(message,queue,routing_key,exchange,delivery_mode,mode)rabbitmq_client.rabbitmq_close_connection()
信息消费者
queue="test_library"size=1# mention number of required messages```heredefaultparameterissize=1```results=rabbitmq_client.rabbitmq_consumer(queue,size)print("number of messages",len(results))rabbitmq_consumer.rabbitmq_close_connection()
python setup.py sdist bdist_wheeltwine upload dist/*python setup.py sdisttwine upload dist/*谢谢
推荐PyPI第三方库
