当前位置: 首页 > 知识库问答 >
问题:

芹菜eventlet工作线程使用过多的数据库连接

高晋
2023-03-14

我有2个芹菜工人,通过eventlet池,配置如下:

celery multi start w1 w2 -A proj -l info --time-limit=600 -P eventlet -c 1000

当一次运行100多个任务时,我会遇到以下错误:

操作错误:致命:剩余的连接插槽保留给非复制超级用户连接

我在PostgreSQL上运行,最大连接数设置为默认值100。

从我在网上读到的,我认为池中的工作线程将共享相同的数据库连接。然而,我的似乎尝试和每个线程创建一个连接,这就是错误发生的原因。

有什么想法吗?

谢谢

共有1个答案

盖绪
2023-03-14

Django有(或有)空闲数据库连接重用,以避免为每个请求创建新连接的开销。空闲重用与此场景无关。

Django从来没有限制数据库连接池。(如有错误,请更正)

考虑总体设计:

  • 你需要并发执行多少任务?(实数通常不是10的好幂)
  • 您的数据库可以支持多少个来自此应用程序的同时连接?
  • 您需要放置人工瓶颈(池)还是需要增加限制并使用可用的硬件?

考虑使用外部[ PostgreSQL连接池](谷歌方括号中的术语)或在应用程序中包含某个地方。

 类似资料:
  • 我使用芹菜独立(不在Django内)。我计划在多台物理机器上运行一种辅助任务类型。该任务执行以下操作 接受XML文档。 转换它。 进行多个数据库读写 我正在使用PostgreSQL,但这同样适用于使用连接的其他存储类型。过去,我使用数据库连接池来避免在每次请求时创建新的数据库连接,或者避免连接打开时间过长。然而,由于每个芹菜工人都在一个单独的过程中运行,我不确定他们实际上如何能够共享游泳池。我是不

  • 我们正在运行气流1.10.1与芹菜。面对多个打开的连接。在DAG启动时,UI会挂起几分钟。 亮点: 所有节点都是裸金属的:CPU:40,MHz 2494.015,RAM 378G,10Gb NIC- MySQL MySQL连接: Worker.cfg Scheduler.cfg: 另外,我正在运行1000个简单任务,比如或

  • 当工作人员在创建之后执行任务时,我不断遇到wierdmysql问题。 我们使用django 1.3,芹菜3.1.17,djorm ext pool 0.5 我们用并发3启动芹菜进程。到目前为止,我的观察是,当工人流程开始时,他们都得到相同的mysql定义。我们将数据库连接id记录如下。 当所有工作人员都获得任务时,第一个任务成功执行,但其他两个任务会出现奇怪的Mysql错误。它要么是“Mysql服

  • 我最近开始研究分布式计算以提高计算速度。我选择了芹菜。然而,我对一些术语不太熟悉。所以,我有几个相关的问题。 来自芹菜文档: ... Celery通过消息进行通信,通常使用代理在客户机和工作人员之间进行调解。为了启动任务,客户机将消息添加到队列中,然后代理将该消息传递给工作者。 什么是客户端(这里)?什么是经纪商?为什么消息通过代理传递?为什么 Celery 会使用后端和队列进行进程间通信? 当我

  • 现在,我想将< code>register事件发布到某个特殊的交换,我可以使用celery远程检索和处理它。 实际上,我已经使用了函数来实现这一点,但是它必须传递来指示应该执行哪个任务并消费它。所以它似乎不太适合我的目标。 我想要的就是这样: 向某些发布消息; 远程机器1订阅此或并捕获消息,用于执行任务; 远程机器2-与机器1相同但执行另一个任务-接收(可能需要回复某些) 例如,就像这个工作流一样

  • 问题内容: 我正在尝试将类的方法用作django-celery任务,并使用@task装饰器对其进行标记。阿南德·杰亚哈(Anand Jeyahar)询问,这里也描述了同样的情况。是这样的 问题是,即使我使用这样的类实例,也需要至少两个参数,这意味着指针未命中。 更多信息: 由于继承,我无法将类转换为 模块 方法在很大程度上依赖于类成员,所以我不能使它们成为 静态的 标记 类 与@task装饰任务,