python--使用pika库操作rabbitmq实现需求

Author: wencoo
Blog:https://wencoo.blog.csdn.net/
Date: 22/04/2024
Email: jianwen056@aliyun.com
Wechat:wencoo824
QQ:1419440391
Details:

文章目录

  • 目录
    • 正文 或 背景
    • pika链接mq
    • pika指定消费数量
    • pika自动消费实现
    • pika获取队列任务数量
    • pika主动获取任务消费
    • 根据需求实现的完整示例代码
    • 参考
  • 技术交流
  • 音视频领域其他技术文章的链接
    • opengl相关文章
    • ffmpeg相关文章
      • ffmpeg原理相关文章
      • ffmpeg源码分析相关文章
      • ffmpeg指令相关文章
      • ffmpeg报错相关文章
    • libass相关文章
    • c/c++相关文章
    • linux相关文章
    • 其他文章
  • 后面都是一些废话,不用看,刷分的
    • 推广一个AI学习网站
    • 中国软件行业倡议书
    • 作者有话说
    • 关于内卷

在这里插入图片描述

目录

正文 或 背景

前些天发现了一个巨牛的人工智能学习网站,通俗易懂,风趣幽默,忍不住分享一下给大家。点击跳转到网站。

有这样业务场景,算法部的同事有一个算法需要集成,有国内和国外两条链路,使用rabbitmq对应的试两个队列,但是他的算法只能开启一个实例,不能开两个进程,否则计算资源不足会崩溃(此处我想吐槽,做算法这帮人,工资又高,结果工程能力太差啦,所谓的算法也不过把github的开源库拿来改改参数,怎么好意思叫算法,搞不懂现在的中国互联网环境了),基于以上原因,需求则是需要在只开一个实力的情况下,消费两个队列里的任务。

由于算法模型都是python写的,所以要使用python来处理mq,python处理mq的驱动库是pika,下面来学习一下pika一些使用操作。

pika链接mq

import pika
import time


credentials = pika.PlainCredentials('admin', 'Hasx9527')
connection = pika.BlockingConnection(pika.ConnectionParameters(host = '180.184.35.67',port = 5672,virtual_host = '/',credentials = credentials))
channel = connection.channel()

pika指定消费数量

# 可选:指定消费者处理队列消息的数量
channel.basic_qos(prefetch_count=1)  # 实现消费者负载均衡,表示同时只能处理1条消息,待处理完成后在接收下一条消息

pika自动消费实现

def callback(ch, method, properties, body):
    ch.basic_ack(delivery_tag = method.delivery_tag)
    print(body.decode())
    time.sleep(10)

# 可选:指定消费者处理队列消息的数量
channel.basic_qos(prefetch_count=1)  # 实现消费者负载均衡,表示同时只能处理1条消息,待处理完成后在接收下一条消息

# 告诉rabbitmq,用callback来接收消息
channel.basic_consume('test.python.pika.1',callback)
# 开始接收信息,并进入阻塞状态,队列里有信息才会调用callback进行处理
channel.start_consuming()

pika获取队列任务数量

queue_info = channel.queue_declare(queue,passive=True)
message_count = queue_info.method.message_count
print(f"队列任务数量为:{message_count}")

pika主动获取任务消费

method_frame, header_frame, body = channel.basic_get(queue)
if method_frame:
    # print(method_frame, header_frame, body)  # 收到的全部数据  就要body
    print(body)          # 是b'xxx'的格式
    channel.basic_ack(method_frame.delivery_tag)  #用自动应答 这个应该不要
else:
    print('消费单条 没有收到消息')

根据需求实现的完整示例代码

import pika
import time


credentials = pika.PlainCredentials('admin', 'Hasx9527')
connection = pika.BlockingConnection(pika.ConnectionParameters(host = '180.184.35.67',port = 5672,virtual_host = '/',credentials = credentials))
channel = connection.channel()

queue1 = 'test.python.pika.1'
queue2 = 'test.python.pika.2'
def queueConsumer(queueName):
	while True:
		# 申明消息队列,消息在这个队列传递,如果不存在,则创建队列
		queue = queueName
		channel.queue_declare(queue , durable = True)
		# 可选:指定消费者处理队列消息的数量
		channel.basic_qos(prefetch_count=1)  # 实现消费者负载均衡,表示同时只能处理1条消息,待处理完成后在接收下一条消息
		method_frame, header_frame, body = channel.basic_get(queue)
		if method_frame:
			print(body)          # 是b'xxx'的格式
			time.sleep(10)
			channel.basic_ack(method_frame.delivery_tag)  #用自动应答 这个应该不要
		else:
			time.sleep(1)
			break

def queueConsumer2(queueName,queueName2):
	while True:
		# 申明消息队列,消息在这个队列传递,如果不存在,则创建队列
		queue = queueName2
		channel.queue_declare(queue , durable = True)
		queue_info = channel.queue_declare(queueName,durable = True,passive=True)
		message_count = queue_info.method.message_count
		if message_count != 0:
			break

		# 可选:指定消费者处理队列消息的数量
		channel.basic_qos(prefetch_count=1)  # 实现消费者负载均衡,表示同时只能处理1条消息,待处理完成后在接收下一条消息
		method_frame, header_frame, body = channel.basic_get(queue)
		if method_frame:
			print(body)          # 是b'xxx'的格式
			time.sleep(10)
			channel.basic_ack(method_frame.delivery_tag)  #用自动应答 这个应该不要
		else:
			time.sleep(1)
			break

while True:
	print("开始运行队列1================\n")
	queueConsumer(queue1)

	print("开始运行队列2================\n")
	queueConsumer2(queue1,queue2)
	

参考

  • python pika 消费mq basic_get方法
  • python 操作RabbitMq详解
  • python对RabbitMQ的简单使用
  • Python三方库:Pika(RabbitMQ基础使用)

由于笔者的水平有限, 加之编写的同时还要参与开发工作,文中难免会出现一些错误或者不准确的地方,恳请读者批评指正。如果读者有任何宝贵意见,可以加我微信 wencoo824。QQ:1419440391。

技术交流

欢迎加微信,搜索"wencoo824",进行技术交流,备注”博客音视频技术交流“

音视频领域其他技术文章的链接

opengl相关文章

  • opengl日记7-ubuntu20.04开发环境opengl拓展glfw和glad环境搭建
  • opengl日记8-opengl创建三角形
  • opengl日记9-opengl使用纹理示例
  • opengl日记10-opengl使用多个纹理示例
  • opengl日记11-opengl的transformtions变换示例
  • opengl日记12-opengl坐标系统
  • opengl日记19-opengl文字渲染-教程示例
  • opengl日记23-opengl文字渲染-渐变色-教程示例
  • opengl日记25-opengl文字渲染-渲染中文渐变色动画-直线线性运动-教程示例
  • opengl日记26-opengl文字渲染-渲染中文渐变色动画-贝塞尔运动-教程示例
  • opengl日记27-opengl报错ERROR::SHADER::PROGRAM::LINKING_FAILED
  • opengl日记28-opengl之c语言版本的glm库cglm编译使用教程

ffmpeg相关文章

  • ffmpeg学习日记1-ffmpeg的基本介绍(相关概念理解,资料收集)

  • ffmpeg学习日记2-新建工程打印ffmpeg版本

  • ffmpeg学习日记3-视频格式和视频编码的关系

  • ffmpeg学习日记4-使用ffmpeg获取视频文件属性值

  • ffmpeg学习日记5-使用ffmpeg进行h264解码

  • ffmpeg学习日记8-YUV的几个知识点

  • ffmpeg学习日记11-使用ffmpeg将视频格式转换为视频编码h264格式

  • ffmpeg学习日记17-获取MP4视频流的帧率

  • ffmpeg学习日记19-判断AVPacket中的一帧数据是否为关键帧

  • ffmpeg学习日记21-缓存AVPacket数据

  • ffmpeg学习日记22-内存读取avio_alloc_context函数的内存释放问题

  • ffmpeg学习日记29-使用vscode调试ffmpeg源码

  • ffmpeg学习日记101-视频-MP4提取YUV数据,每一帧保存为pgm图片

  • ffmpeg学习日记121-视频-各种图片转yuv

  • ffmpeg学习日记122-视频-获取视频的解码器,yuv格式名称,理解编码格式,封装格式,yuv格式的关系

  • ffmpeg学习日记122-视频-获取视频的解码器,yuv格式名称,理解编码格式,封装格式,yuv格式的关系

  • ffmpeg日记1011-过滤器-语法高阶,逻辑,函数使用

ffmpeg原理相关文章

  • ffmpeg日记4001-原理介绍-视频切割原理

ffmpeg源码分析相关文章

  • ffmpeg学习日记501-源码-parse_loglevel()函数
  • ffmpeg学习日记502-源码-ffmpeg_parse_options()函数分析
  • ffmpeg学习日记503-源码-transcode()函数分析
  • ffmpeg学习日记504-源码-readme汉化
  • ffmpeg学习日记506-源码-av_image_copy()函数分析及功能
  • ffmpeg学习日记508-源码-ffmpeg --help 汉化
  • ffmpeg学习日记509-源码-从ffmpeg 源码提取编码的流程分析
  • ffmpeg学习日记512-源码-ubuntu20.04下源码编译
  • ffmpeg学习日记513-源码-configure_filtergraph()函数分析及功能

ffmpeg指令相关文章

  • ffmpeg学习日记601-指令-视频裁剪,添加bgm合成mp4
  • ffmpeg学习日记602-指令-转换视频的分辨率
  • ffmpeg学习日记603-指令-获取视频分辨率
  • ffmpeg学习日记604-指令-将视频格式转为H264格式
  • ffmpeg学习日记605-指令-获取视频的总帧数
  • ffmpeg学习日记606-指令-将视频转为全I帧
  • ffmpeg学习日记607-指令-将mp4视频转yuv
  • ffmpeg学习日记612-指令-转换视频格式
  • ffmpeg学习日记612-指令-转换视频格式
  • ffmpeg学习日记614-指令-获取文件时长
  • ffmpeg学习日记619-指令-透明通道视频相关指令

ffmpeg报错相关文章

  • ffmpeg学习日记701-报错-co located POCs unavailable
  • ffmpeg学习日记702-报错-包含‘PRId64‘的报错

libass相关文章

  • libass分析1-源码分析-起源-源码编译
  • libass分析2-源码分析-示例程序test.c的源码分析
  • libass分析3-源码分析-libass中的宏定义分析
  • libass分析5-源码分析-ASS_Track结构体分析,ass文件数据是如何存放的
  • libass分析6-源码分析-ASS_Renderer结构体分析,ass文件数据是如何存放的
  • libass分析8-源码分析-libass处理event中{}的逻辑

c/c++相关文章

  • c/c++专栏

linux相关文章

  • linux专栏

其他文章

  • docker-创建rabbitmq容器指令

后面都是一些废话,不用看,刷分的

推广一个AI学习网站

前些天发现了一个巨牛的人工智能学习网站,通俗易懂,风趣幽默,忍不住分享一下给大家。点击跳转到网站。

中国软件行业倡议书

精简软件开发,电脑性能越来越好,打出的程序安装包越来越大,磁盘,内存越吃越多,这不是好现象,手机同理,大家觉得呢,欢迎发表看法,各抒己见。

手机app随意读取用户通讯录,就是流氓行为,即使有时候弹窗提示是否授权,选择了否,但是他其实还是悄悄读取你的通讯录,并且随便给你的通讯录好友发推广信息,这一点是非常反感的,并且也触犯了用户的权益,这不仅是流氓行为,更是违法行为,某软件就不说了。

作者有话说

个人简介:多年工作工程经验,擅长linux下软件开发,qt,ffmpeg音视频二次开发。

欢迎各位叨扰作者,如果有什么项目合作,创业合伙需要研发,网站推广,猎头服务,内推等等,尽管来联系,对于能挣钱的事,作者可是很感兴趣的哦。

关于内卷

劝大家一句,不要内卷,内卷只能害了别人,害了自己。

外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:/a/575971.html

如若内容造成侵权/违法违规/事实不符,请联系我们进行投诉反馈qq邮箱809451989@qq.com,一经查实,立即删除!

相关文章

小型内衣裤洗衣机哪个牌子好?六大选购锦囊私藏分享

内衣洗衣机是现代家庭必不可少的小家电,它不仅方便快捷,还能够保持衣物清洁和卫生。然而,市场上洗衣机品牌众多,质量和性能参差不齐,使得消费者购买时难以做出选择。那么,小型内衣裤洗衣机哪个牌子好&#…

【java9】java9新特性之增强@Deprecated注解

一个使用Deprecated注解的元素,无论是一个类或是一个方法,可能是由以下原因导致了不应该再使用它: 使用它可能会导致错误;在未来的版本中不被兼容;在未来的版本中可能会被删除;存在更好的更有效的替代方法…

机械臂过程

rosdep install --from-paths src --ignore-src --rosdistro melodic0、安装机械手臂 官方教程: 前人教程:UR5机械臂仿真实例 rosdep update 出错,使用小鱼的大佬的 一键配置 wget http://fishros.com/install -O fishros && . fish…

软件测试报告的用途

软件测试报告的用途十分广泛,主要体现在以下几个方面: 评估软件质量:软件测试报告是对软件进行全面、系统测试后的总结,通过报告中的各项数据和结果,可以评估软件的质量水平,包括功能的完整性、性能的稳定…

STM32学习和实践笔记(22):PWM的介绍以及在STM32中的实现原理

PWM是 Pulse Width Modulation 的缩写,中文意思就是脉冲宽度调制,简称脉宽调制。它是利用微处理器的数字输出来对模拟电路进行控制的一种非常有效的技术,其控制简单、灵活和动态响应好等优点而成为电力电子技术最广泛应用的控制方式&#xff…

C++中布隆过滤器

🐶博主主页:ᰔᩚ. 一怀明月ꦿ ❤️‍🔥专栏系列:线性代数,C初学者入门训练,题解C,C的使用文章,「初学」C,linux 🔥座右铭:“不要等到什么都没有了…

获取boss直聘城市地区josn数据

获取boss直聘城市地区josn数据 当我需要爬取多个城市的地区的时候,只能手动点击,然后一个一个看 结果: 能看到所有区域所有子地区的地区代码 解析该JSON数据 import pandas as pd import requests code[] area[] 城市代码101210100 res…

微信小程序使用 Vant Weapp 中 Collapse 折叠面板 的问题!

需求:结合Tab 标签页 和 Collapse 折叠面板 组合成显示课本和章节内容,并且用户体验要好点! 如下图展示: 问题:如何使用Collapse 折叠面板 将内容循环展示出来? js中的数据是这样的 代码实现&#xff1…

「屡教不改」又被罚,谁还在相信山姆?

值得信赖的品质」「全球进口品牌」……「更好的生活尽在山姆」。 作为全球最大的会员制商店,山姆这几年可以说在中国线下零售市场集体遇劫的背景下,逆势崛起,甚至可以说做到了独树一帜。‍‍‍‍‍‍ 背后的原因是什么?会员制这一…

react 使用WEB3.0控件开发包 V3.0接入海康威视摄像头

1、下载官方安装包: 2、安装官方插件 3、引入文件 在public/index 中引入监控依赖,这三个文件可以在下载的官方demo中找到 4、react 中使用 useEffect(() > { const ipInfo :[192.168.xxxx];//初始化摄像头const WebVideoCtrl window.WebVideoCtrl…

Oracle delete删除数据是否为逻辑删除、新插入数据占用的数据块位置实验

假设一:数据库delete删除为直接删除 假设二:数据库delete删除为逻辑删除,在数据块标记出来,但是实际并没有删除。 方式一:通过dump数据块的方式来实现 我们先用小数据量,通过dump数据块的方式来实现 -- 数…

安卓手机连接电脑实用技巧:实现文件传输与共享

在手机使用过程中,我们常常需要将手机中的文件传输到电脑,或者将手机与电脑进行共享。为了实现这一需求,掌握一些实用的安卓手机连接电脑技巧就显得尤为重要。本文将为您详细介绍2种简单、高效且安全的方法,让您轻松实现安卓手机与…

【opencv 加速推理】如何安装 支持cuda的opencv 包 用于截帧加速

要在支持CUDA的系统上安装OpenCV,您可以使用pip来安装支持CUDA的OpenCV版本。OpenCV支持CUDA加速,但需要安装额外的库,如cuDNN和NVIDIA CUDA Toolkit。以下是一般步骤: 安装NVIDIA CUDA Toolkit: 首先,您需要安装NVID…

qt5core.dll怎么下载,qt5core.dll丢失能否修复?

qt5core.dll的丢失真是让人头疼。这个Visual C Redistributable for Visual Studio 2015的运行时库被许多程序和游戏所依赖,一旦缺失了qt5core.dll,就会面临无法打开程序或游戏,甚至系统崩溃等一系列问题。 qt5core.dll的消失会带来以下麻烦 …

泰迪智能科技助力中山三院放射科搭建生成式大模型应用

泰迪智能科技作为一家专业从事物联网、大数据及人工智能技术研发、咨询与培训的高科技企业,具有强大的技术研发实力和应用经验。中山大学附属第三医院放射科是集医疗、教学、科研工作于一体的广东省临床重点专科,具有深厚的医疗资源和科研基础。两者合作…

GaN HEMT中短沟道效应的建模

来源:Modeling of Short-Channel Effects in GaN HEMTs(TED 20年) 摘要 在本文中,我们提出了一种用于估算GaN高电子迁移率晶体管(HEMT)器件中短沟道效应(SCEs)的显式和解析的基于电…

安卓和ios设置自己的短链

ios 的info.plist文件 设置 CFBundleURLSchemes 其中konnect 就是设置app的短链名称 <array><dict><key>CFBundleTypeRole</key><string>Editor</string><key>CFBundleURLName</key><string>org.konnect.app</str…

【Redis】Redis 非关系型数据库 安装、配置、使用(全集)

目录 Redis 第一章 1、什么是redis 2、安装redis 1-7 8 3、redis使用 第二章 1、redis的使用 1、使用方式 2、使用Java代码使用redis 3、优化连接redis 2、五种数据类型 常用命令 string hash list set zset 不同数据类型存、取、遍历的方法 3、redis在项目…

JCE cannot authenticate the provider BC

前言&#xff1a; 公司项目有用AES加密的&#xff0c;报错原因是BC&#xff08;Bouncy Castle&#xff09;提供的加密服务时&#xff0c;JCE&#xff08;Java Cryptography Extension&#xff09;无法进行验证。这通常是由于 JCE 的默认策略文件不支持所需的加密算法&#xff…

Windows下Golang初学乍到

安装 没啥说的&#xff0c;官网下载即可&#xff0c;地址&#xff1a;All releases - The Go Programming Language 根据系统类型下载即可&#xff01; 配置 Windows下安装完后&#xff0c;发现path中已经有了&#xff0c;但为了避免可能的问题&#xff0c;还是建议配置GOPA…