• 一首歌可以循环一整天《我们都是好孩子》
  • 在别人眼里是逃避,其实是不想牵累任何人,做孤独的自己。
  • 也许有一天我会背着包,独自漂流。
  • 既然做了决定,就不后悔,再见昆明!
  • 愿闻世间百态。
  • 外表的一切如常,内心的混乱又有谁能了解!
  • 突然想回安徽工作了!
  • 梦到你结婚了,瞬间惊醒。
  • 51152>–<25287
  • 该来的还是来了,Uzi宣布退役!

Python消费RabbitMQ消息

脚本 愿闻世间百态 2年前 (2021-02-24 14:01:58) 3545次浏览 已收录 0个评论
代码演示如下:

import pika
import time
import json
import pyttsx3

auth = pika.PlainCredentials(
    username='admin',
    password='admin123#$',
) # 用户名 / 密码
connection = pika.BlockingConnection(
    pika.ConnectionParameters(
        '10.9.101.60', # RabbitMQ 地址
        5672, # 端口号
        'test-host', # 虚拟主机
        auth, # 验证
    )
) # 链接 RabbitMQ
channel = connection.channel() # 创建 RabbitMQ 通道

channel.queue_declare(
    queue='event.send', # 消费对列名
    durable=True, # 持久化
)

def speak(camera_name,event_name):
    # 语音识别
    speaker = pyttsx3.init()
    speaker.say('警告:'+camera_name+'发生'+event_name)
    speaker.runAndWait()

num = 1
def callback(ch, method, properties, body):
    global num
    body = body.decode('utf-8', 'ignore')
    body = json.loads(body)
    check_body(num,body)
    num = num+1
    #print(body)

def check_body(num,body):
    print('-----------------------%s------------------------------'%num,'\n'
        "报警时间:" + time.strftime("%Y-%m-%d %H:%M:%S",time.localtime(body[0]['alarm_time']/1000)),'\n'
        "报警事件:" + body[0]['event_name'],'\n'
        "报警等级:" + body[0]['event_level'],'\n'
        "摄像机名称:" + body[0]['camera_no'],'\n'
        "摄像机 ID:" + body[0]['camera_id'],'\n'
        "摄像机 IP:" + body[0]['camera_ip'],'\n'
        "用户名:" + body[0]['camera_username'],'\n'
        "密码:" + body[0]['camera_password'],'\n'
        "UUID:" + body[0]['uuid'],'\n'
        "报警截图:" + body[0]['pic_url'],'\n'
        "报警录像:" + body[0]['rec_path'])
    speak(body[0]['camera_no'], body[0]['event_name'])

channel.basic_consume(
    queue='event.send', # 对列名
    auto_ack=True, # 自动回应
    on_message_callback=callback, # 回调消息
)
time.sleep(1) # 模拟消费时间
print("开始接收报警信息!")
channel.start_consuming()


WECV.CN , 版权所有丨如未注明 , 均为原创丨本网站采用BY-NC-SA协议进行授权
转载请注明原文链接:Python 消费 RabbitMQ 消息
喜欢 (0)
[]
分享 (0)

您必须 登录 才能发表评论!