中间件

MQ

连接mq队列，推送mq消息

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
import pika
import json

message = {'apiCode': '3005', 'apiUser': '08cs', 'requestIp': '10.4.1.196', 'requestTime': 1726743703912,
           'result': 0, 'transactionId': '1a1b47d4-c458-433e-90ca-bde36bd4fcf1'}


message_json = json.dumps(message)


connection = pika.BlockingConnection(
    pika.ConnectionParameters(host='172.20.30.14')
)
channel = connection.channel()


channel.queue_declare(queue='yzf.api.invoke.log.queue', durable=True)


channel.basic_publish(
    exchange='',
    routing_key='yzf.api.invoke.log.queue',
    body=message_json,
    properties=pika.BasicProperties(
        delivery_mode=2,
    )
)

connection.close()