程序员经验分享-hwhale

Pika：写入缓冲区超出警告

2024-01-30

我们的软件程序运行良好 5 个月，现在突然开始收到 Pika 警告，最终导致异常。

Pika 0.9.5 用户警告：写入缓冲区超出警告阈值。

我搜索了很多论坛，但都不满意。所描述的一种解决方案是完全忽略这些警告，但我对此有点怀疑。对此问题的任何帮助将不胜感激。这是非常紧急的。

Thanks


This: http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/2011-4月/012223.html http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/2011-April/012223.html很好地解释了问题。问题是你写入的速度比从队列中消费的速度快得多。警告只是告诉你这一点。

您可以调整：

connection.set_backpressure_multiplier(NNNN)

但这并不能解决问题，只是会隐藏警告一段时间。

根据应用程序 - 您可能需要附加一些代码add_backpressure_callback: http://pika.github.com/connecting.html#adapters.select_connection.SelectConnection.add_backPressure_callback http://pika.github.com/connecting.html#adapters.select_connection.SelectConnection.add_backpressure_callback

并在受到背压时进行一些清理或所需的任何操作。但首先 - 检查您的代码并找出导致过载的原因。

本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系:hwhale#tublm.com(使用前将#替换为@)

python

rabbitmq

pika

Pika：写入缓冲区超出警告 的相关文章

  • 导入错误：无法导入名称“FFProbe”

    我无法获取ffprobe包 https github com simonh10 ffprobe在 Python 3 6 中工作 我使用 pip 安装它 但是当我输入import ffprobe it says Traceback most

  • 如何替换Python字符串中的正确字母

    任务是 您的任务是纠正数字化文本中的错误 您只需处理以下错误 S 被误解为 5 O 被误解为 0 I 被误解为 1 我的代码 def correct string for i in string if 5 in string string

  • 如何同时运行多个功能[关闭]

    Closed 这个问题需要多问focused help closed questions 目前不接受答案 我有以下代码 my func1 my func2 my func3 my func4 my func5 是否可以同时计算函数的数据 而

  • 使用管理员权限打开cmd（Windows 10）

    我有自己的 python 脚本来管理我的计算机上的 IP 地址 它主要在命令行 Windows 10 中执行netsh命令 您必须具有管理员权限 这是我自己的计算机 我是管理员 运行脚本时我已经使用管理员类型的用户 Adrian 登录 我无

  • 使用 Boto3 超时的 AWS Lambda 函数

    我已经解决了我自己的问题 但无论如何我都会发布它 希望能节省其他人几个小时 我在 AWS 上有一个无服务器项目 使用 Python 将记录插入到 kinesis 队列中 但是 当我使用 boto3 client kinesis 或 put

  • 使用 Python 和 lmfit 拟合复杂模型？

    我想适合椭偏仪 http en wikipedia org wiki Ellipsometry使用 LMFit 将数据转换为复杂模型 两个测量参数 psi and delta 是复杂函数中的变量rho 我可以尝试将问题分离为实部和虚部共享参

  • 动态字段取决于 WTForms 的先前字段

    我正在使用 WTForms 制作表格 目前 我有这个 class UploadForm flask wtf Form fichier wtforms fields FileField u Fichier description wtform

  • 使用 Tkinter 打开网页

    因此 我的应用程序需要能够打开其中的单个网页 并且它必须来自互联网并且未保存 特别是我想使用 Tkinter GUI 工具包 因为它是我最熟悉的工具包 最重要的是 我希望能够在窗口中生成事件 例如单击鼠标 但无需实际使用鼠标 有什么好的方法

  • 为什么需要设置WORKON_HOME环境变量？

    我已经有一段时间没有使用 python 虚拟环境了 但我也安装了虚拟环境包装器 我的问题是 在文档页面中它说要这样做 export WORKON HOME Envs mkdir p WORKON HOME source usr local

  • 列表推导式和 for 循环中的 Lambda 表达式[重复]

    这个问题在这里已经有答案了 我想要一个 lambda 列表 作为一些繁重计算的缓存 并注意到这一点 gt gt gt j for j in lambda i for i in range 10 9 9 9 9 9 9 9 9 9 9 Alt

  • 我可以用关闭的文件对象做什么？

    当您打开文件时 它存储在一个打开的文件对象中 该对象使您可以访问该文件的各种方法 例如读取或写入 gt gt gt f open file0 gt gt gt f

  • 如何从 python 脚本执行 7zip 命令

    我试图了解如何使用 os system 模块来执行 7zip 命令 现在我不想用 Popen 或 subprocess 让事情变得复杂 我已经安装了 7zip 并将 7zip exe 复制到我的用户文件夹中 我只想提取我的测试文件 inst

  • Flymake的临时文件可以在系统临时目录下创建吗？

    我目前正在使用以下代码在 emacs 中连接 Flymake 和 Pyflakes defun flymake create temp in system tempdir filename prefix make temp file or

  • 哪种方式最适合Python工厂注册？

    这是一个关于这些方法中哪一种被认为是最有效的问题 Pythonic 我不是在寻找个人意见 而是在寻找惯用的观点 我的背景不是Python 所以这会对我有帮助 我正在开发一个可扩展的 Python 3 项目 这个想法类似于工厂模式 只不过它是

  • 获取多个同名请求参数

    我的问题是给定的代码 from flask import Flask request app Flask name app route def hello return str request values get param None a

  • 如何创建增量加载网页

    我正在编写一个处理大量数据的页面 它会永远持续到我的结果页面加载 几乎无限 因为返回的数据太大了 因此 我需要实现一个增量加载页面 例如 url 中的页面 http docs python org http docs python org

  • 如何检测一个二维数组是否在另一个二维数组内？

    因此 在堆栈溢出成员的帮助下 我得到了以下代码 data needle s which is a png image base64 code goes here decoded data decode base64 f cStringIO

  • 如何将两列 pandas Dataframe 移动并堆叠为一列？

    我有一个下面提到的数据框 ETHNIC SEX USUBJID 0 HISPANIC OR LATINO F 16 1 HISPANIC OR LATINO M 8 2 HISPANIC OR LATINO Total 24 3 NOT H

  • AWS 将 MQTT 消息存储到 DynamoDB

    我构建了一个定期发送 MQTT 消息的 python 脚本 这是发送到后端的 JSON 字符串 Id 1234 Ut 1488395951 Temp 22 86 Rh 48 24 在后端 我想将 MQTT 消息存储到 DynamoDB 表中

  • 如何有效地比较 pandas DataFrame 中的行？

    我有一个 pandas 数据框 其中包含雷击记录以及时间戳和全球位置 格式如下 Index Date Time Lat Lon Good fix 0 1 20160101 00 00 00 9962692 7 1961 60 7604 1

随机推荐

  • 如何从ContainerRequestContext获取数据来构建DTO对象

    我是春季和球衣的新人 我正在尝试构建一个过滤器来检查请求是否具有正确的参数 这是我要检查的 json 部分 request application 1 Android Mobile version 1 数据元素是我的 VersionDTO

  • Java 8 epoch-millis 时间戳到格式化日期，如何？

    在 Java 8 之前 我习惯于始终将任何与日期 时间相关的内容保留为自纪元以来的毫秒数 并且仅在退出时处理人类可读的日期 时间 即在 UI 或日志文件中 或在解析用户生成的输入时 我认为这对于 Java 8 来说仍然是安全的 现在我正在寻

  • RestKit - 将数组的键路径映射到该数组内部的对象

    我真的很喜欢用 RestKit 0 20 来解析这个特定的响应 addons id 1 name Addon one version 2 id 2 name Addon two version 3 forms id 1 name Form

  • 在 Python 中打印格式正确的 SQLite 表

    我编写了一个 Python 脚本来向表中添加行 我决定如果我也可以使用相同的脚本查看我的表 而不必退出脚本并运行 sqlite3 或切换到另一个 shell 并运行 sqlite3 那就太好了 所以我写下了我期望的内容 它会给我我想要的东西

  • Angular - 单击时使用动态 ID 专注于输入

    有很多类似的问题 但我还没有找到真正的重复问题来回答我的问题 如果我错过了一些东西 我深表歉意 我有一个包含多个输入 按钮的页面 重复相同的组件 并且需要在单击按钮时关注正确的输入 我尝试过 elementRef nativeElement

  • 将文本添加到 MySQL 列名称之前

    假设一个查询例如 SELECT FROM tableA 我怎样才能前置a 每列的名称 例如 如果有一列 用户名 它将在结果中作为 a username 进行访问 EDIT The SELECT username AS a username格

  • Rails 3 原型渲染：更新响应具有 text/html 内容类型

    我正在尝试让一些用原型和 Rails 2 3 11 编写的 RJS 代码在 Rails 3 2 1 中工作 我有prototype rails宝石 所以render update do page 有效 我正在使用一个表单 remote gt

  • 如何快速创建指向 Eclipse 中元素的 Javadoc 链接？

    我想在我的 Javadoc 中轻松创建类 方法 字段等的链接 而无需键入完整的表达式 例如 link AllowAllHostnameVerifier 在 Eclipse 中执行此操作最快的方法是什么 If you don t alread

  • 如何使用 PostgreSQL 将字符串转换为 unicode？

    在这里我想将我的字符串转换为unicode 我使用的是 PostgreSQL 9 3 版本 在 SQL Server 中 这要简单得多 Example sql N select from tabletest For nvarchar nch

  • UITableViewController 中的复制/粘贴功能

    我有一个 UITableViewController 我想在用户触摸单元格时弹出复制 粘贴菜单 我想像在 通讯录 应用程序中那样进行操作 如何实现这个功能 有人能帮我吗 我试过这段代码 UIMenuController theMenu UI

  • 编译时出错：“预期的类、委托、枚举、接口或结构”

    这段代码有什么问题 该程序旨在复制文件并将其通过电子邮件发送到电子邮件地址 但事实并非如此 using System using System Collections Generic using System ComponentModel

  • 为什么docker容器会立即退出

    我使用在后台运行一个容器 docker run d name hadoop h Service 它很快就退出了 但如果我在前台运行 它工作得很好 我使用检查日志 docker logs hadoop 没有错误 有任何想法吗 Dockerfi

  • python 图像库保存函数

    我刚刚使用 python 图像库 PIL 完成了一些图像处理 但无法使保存功能正常工作 整个代码工作正常 但它只是不会保存结果图像 代码如下 im Image new rgb 200 10 ddd draw Image draw draw

  • 在 C 中分配 128 位整数

    当我尝试在 gcc 4 9 1 中分配一个 128 位整数时 我得到一个warning integer constant is too large for its type 示例代码 int main void uint128 t p 47

  • for-await-of 简单示例（打字稿）

    在 typescript 2 3 中引入了一个新功能 for await of 任何人都可以发布一个简单的示例来说明如何将其与 Promise 一起使用以及其主要用例是什么 我正在研究更改日志中的示例 async function f fo

  • 如何根据另一个元素的高度调整列的高度？

    我在左侧有一种间隔列 实际上我希望它的高度与该页面上文本的长度相同 这显然因页面而异 这是CSS sidebox width 200px height 2000px float left padding 5px background f4f

  • 在唯一列中的行之间切换值

    假设您有一张这样的表 id name 1 foo 2 bar 存在唯一性约束name column 你会如何设置行id 2 to foo 以及行id 1 to bar 我知道您可能只需为两者分配临时名称 然后粘贴所需的名称 但这似乎不是最简

  • Windows API CreateFile() 中 OPEN_ALWAYS 和 CREATE_ALWAYS 的区别

    谁能解释一下创造配置之间有什么区别OPEN ALWAYS and CREATE ALWAYS of the 创建文件 http msdn microsoft com en us library aa363858 28VS 85 29 asp

  • 静态只读字段的初始化顺序[重复]

    这个问题在这里已经有答案了 我很好奇 C 规范对 C 5 net4 中静态字段的初始化顺序有何说明 例如 public class Test public static readonly string A hi public static

  • Pika：写入缓冲区超出警告

    我们的软件程序运行良好 5 个月 现在突然开始收到 Pika 警告 最终导致异常 Pika 0 9 5 用户警告 写入缓冲区超出警告阈值 我搜索了很多论坛 但都不满意 所描述的一种解决方案是完全忽略这些警告 但我对此有点怀疑 对此问题的任何

热门标签