问题标签 [python-gearman]

我正在尝试更改 python-gearman 工人在其工作周期内可用的任务。我这样做的原因是允许我对我的工作进程进行一点控制，并允许它们从数据库中重新加载。我需要每个工作人员定期重新加载，但我不想简单地终止进程，我希望服务始终可用，这意味着我必须分批重新加载。所以我会让 4 名工人重新加载，而另外 4 名工人可以处理，然后重新加载接下来的 4 名工人。

过程：

1. 开始重新加载过程 4 次。
   1. 注销reload进程
   2. 重新加载数据集
   3. 注册一个finishReload任务
   4. 返回
2. 重复步骤 1，直到没有reload注册任务的工作人员。
3. 开始finishReload(1) 任务，直到没有finishReload可用任务的工人。

(1)finishReload任务注销finishReload任务并注册reload任务然后返回。

现在，我遇到的问题是，当我更改工作进程可用的任务时，作业会失败。没有错误消息或异常，gearmand 日志中只有一个“错误”。这是一个复制问题的快速程序。

工人

客户

请让我知道是否有任何我可以解释的事情。

编辑：我知道有人会要求查看我提到的日志。我也将这个问题发布到了 Google 上的 gearman 组，并且那里有日志。

我想在项目中实现“GEARMAN”，但我不知道如何在 Windows 操作系统中安装或配置“GEARMAN”。谁能提供我可以使用“GEARMAN”的任何链接？

我需要通过这些 un​​iq id 获取 Gearman 作业的状态，而不是通过打开的处理程序，正如我看到的每个地方所描述的那样

可能吗？在 python-gearman v. 2 中使用...

感谢您的帮助！

我正在尝试将 gearman 与背景任务一起使用，并从工作人员那里获取数据进度。在文档中，我看到了方法：send_job_data 和 send_job_status，但使用后台第一种方法不起作用（我在 job.data_updates 中看不到数据），但 job.status 中的状态发生了变化。

我将此代码用于测试人员： from gearman import GearmanWorker import time

来自客户端的这段代码： from gearman import GearmanClient client = GearmanClient(['192.168.1.79:4730'])

此代码（阻塞）工作正常：

而且这个客户端不能正常工作（不更新任务状态并且不获取数据/结果）:(

我怎样才能正常获取这些数据？因为我的后台任务将工作几个小时并在消息中发送有关我们状态的信息。

我正在使用gearman来同步不同服务器上的数据。我们有1 台主服务器，例如 10 台本地服务器。让我描述一种可能的情况。比如说，gearman 开始工作，完成了 5 个工作，同步了 5 个服务器上的数据。当开始下一个工作时，比如说，我们失去了与服务器的连接，现在它不可用。根据 gearman 的逻辑，它会一次又一次地重试。所以剩下的作业（对于服务器 7、8、9、10）将不会执行，直到第 6 个没有完成。最好的解决方案是推迟工作并将其置于队列末尾并继续工作 7-10。

如果有人知道如何做到这一点，请张贴方式。

PS：我正在使用python。

例如：我有一个名为“URLDownload”的任务，该任务的功能是从互联网上下载一个大文件。现在我有一个工作进程正在运行，但有大约 1000 个文件要下载。客户端进程很容易创建 1000 个任务，并将它们发送到 Gearman 服务器。

我的问题是工作进程会一个一个地完成任务，或者它会一次接受多个任务，

如果 Worker Process 可以接受多任务，那么如何限制 Worker Process 中的 task-pool-size。

我使用 django-gearman-commands 来做一些像这个文档（http://pypi.python.org/pypi/django-gearman-commands/0.1）说的工作。当我第一次运行工人时，它工作得很好，但是当我提交另一份工作时，就像从数据库中进行选择查询一样，它无法工作，直到我重新启动这个工作人员，我发现工作人员一次可以正常工作。当工人不能很好地工作时，它仍然可以获得我提交的价值，但不能继续工作。我希望有一个人可以帮助我 。这是我的代码：

当我第一次提交工作时，它运行良好，然后我提交另一个工作，它说找不到任何帖子。

I am trying to run a basic example of gearman using python-gearman library available here. I am running python 2.7.3

Worker:

Client:

I am getting the following error (full trace available here)

Any help would be appreciated!

Thanks.

任何人都可以推荐或创建一个关于如何制作类似于 Facebook 只使用 Django、Tastypie（Django 的 Web 服务 API 框架）、Redis（键值存储）和 Gearman（任务队列）的新闻提要的教程吗？

目前我有用户模型、帖子模型、收藏模型和评论模型。我用这些模型创建了 Tastypie 资源，以允许收藏、喜欢、评论和发布。

我想知道如何生成直接应用于用户的提要操作。例如：

我真的需要有关如何使用上述技术构建活动提要的深入示例和教程。任何帮助，将不胜感激。

如何判断 Gearman 客户端的后台作业或非阻塞请求是否成功？