发布时间:2019-09-01 09:51:05编辑:auto阅读(2040)
#!/usr/bin/env python
#-*- coding: utf8 -*-
import pika
import traceback
try:
connection = pika.BlockingConnection(pika.ConnectionParameters(host='192.168.4.226'))
channel = connection.channel()
except:
print traceback.print_exc()
def rabbitmq_send(abcde):
try:
channel.queue_declare(queue='abcde')
except:
print traceback.print_exc()
try:
mess = "<message><name>abcde</name><item key='abcde'>%s</item></message>" %abcde
channel.basic_publish(exchange='',
routing_key='abcde',
body = mess)
print '[x] Send abcde'
except:
print traceback.print_exc()
try:
connection.close()
except:
print traceback.print_exc()
if __name__ == "__main__":
sc = rabbitmq_send('abcde')
上一篇: python实现ftp上传
下一篇: python set(集合)
50546
49864
40456
37449
31878
28758
27677
22458
22455
20767
552°
1174°
957°
883°
1141°
1000°
1624°
3010°
2729°
2056°