问题标签 [pheanstalk]

I am a little confused as to whether priorities work at the job or queue/tube level. The reason I ask is that I am using a beanstalkd integration module in Drupal. This module enables one to define queues/tubes and assign a priority value to each queue/tube created.

What I am trying to work out is the following. Let's say I have two queues/tubes in Beanstalkd (queue A and queue B). If items assigned to Queue A have a higher priority than items in Queue B, does that mean items in Queue B will only be processed when Queue A is empty?

我在 php 应用程序中使用带有 Pheanstalk Connection 的 Beanstalk 服务器。

以前还好，突然就报错了

我正在尝试创建一个在后台运行并分叉子进程的 PHP 脚本。（我知道这可能会导致服务器爆炸；还有一些超出此问题范围的额外保护措施）

简而言之，代码的工作方式如下：

问题是，一旦我分叉了这个过程，我就会得到错误：

我的问题是，pheanstalk 是如何返回一个没有 ID 和有效负载的工作的？一旦我 fork 它几乎感觉就像 $pheanstalk 损坏了。如果我删除分叉，一切正常。（虽然它必须等待每个进程）

我正在尝试让 beanstalk 启动并运行，并且在尝试运行 Queue::push() 时遇到异常：

我已经运行了composer require pda/pheanstalk，甚至重新生成了我的自动加载文件。

它发生在 ./vendor/laravel/framework/src/Illuminate/Queue/Connectors/BeanstalkdConnector.php

有任何想法吗？

我试图让 Pheanstalk 为 PHP 工作，但我无法加载它。

我从下载源代码https://github.com/pda/pheanstalk，将 src/Pheanstalk 移动到我的项目目录，然后在中执行以下操作test.php：

但这给了我以下错误：

如何从克隆的 git 存储库中使用 Pheanstalk？

我的堆栈设置包括以下

Machine1 - 主服务器（运行 laravel） Machine2
- laravel代码库的 MySql 服务器 Machine3 - Beanstalkd worker 我在 Machine1 上设置了 Supervisord
并添加了以下队列侦听器

我的 laravel 队列配置文件（app/config/queue.php）读取以下内容

我已经在 Machine3 上安装了 beantalkd和Beanstalk 控制台，可以看到我的任务被推送到队列并成功执行。但是我不确定Machine3是否真的在执行它们，我怀疑的原因是主服务器上的 CPU 使用率很高，而Machine3上的 CPU 使用率没有峰值

我完全关闭了 beanstalkd 服务器以检查队列是否仍在处理，结果是 laravel 报告的错误，表明它无法连接到 beanstalkd 服务器。

我在某处读到你也需要在 beanstalkd 服务器（ Machine3 ）上拥有你的 laravel 代码库，这真的是要走的路吗？

在 Beanstalkd 中，当一个作业命中 TTR 时，它将杀死处理该作业的工作人员并将该作业释放回池中。在我们的系统中，这应该是一个非常罕见的事件，在这种情况下，我宁愿埋葬这份工作。

怎么做呢？

（如果重要的话，我们使用 PHP + Pheanstalk）

我正在使用 beastalkd 来处理电子邮件验证的作业队列。

作业处理器的实现就像

就像上面的示例一样，在某些时候会抛出异常，该异常会根据流程缩进发生。异常是正确捕获并在 catch 块中执行一些操作。问题是在捕获释放回队列的异常之后。

即使在异常捕获之后，是否有任何方法可以继续处理作业的当前尝试。?

我在用

当我尝试

它返回

邮件功能（信任包）

我如何让我的员工要求更多的时间来工作？

我正在使用 pheanstalk 库。工作是对文件的解析，取决于文件可能需要超过 60 秒，默认 ttr。

我是排队的新手，我一直在浏览我在网上找到的例子。如果我做错了，请告诉我。我试图获取 jobstats 并根据剩余时间值编写条件，但我无法让它工作。当我在 pheanstalk 中使用 jobStats 函数时，结果是一个私有对象数组。我想要的是让脚本等到执行完成，无论这可能需要多长时间。