问题标签 [chord]

使用芹菜，我构建了一个和弦：

但是，它通常会引发超时：

有没有办法修改超时设置以允许这种芹菜设计？

请注意，每个任务中都有子任务，因此链似乎并不能确保在开始下一个任务之前所有子任务都已完成。

另一个限制是我不能通过get()两个步骤调用来执行此操作，因为这些和弦已经在任务中构建。

我是 Shiny 的新手，正在尝试将和弦图添加到闪亮的服务器。当我在 RStudio 中点击 runApp 按钮时，我让应用程序运行并生成 UI，但随后立即关闭，并且在 RConsole 窗口中出现以下错误：（结构中的错误（函数（输入，输出）：无法找到函数“渲染图”。

不幸的是，我无法附加数据，因为它是专有的，但我只是创建一个邻接矩阵来生成和弦图。Chord 情节在 Shiny 之外运行良好。提前致谢！

我的用户界面和服务器代码如下：

使用Chord我可以在浏览器中成功打开 Clojurescript 套接字连接。

然而，文档和随附的示例似乎没有列出关闭该连接的任何选项。有谁知道这应该怎么做？

我有一个复杂的工作流程，它是产生和弦的和弦的和弦。不调用上和弦回调。所有内部任务都已完成。

这是工作流程：

并且每个内部组（标有**）创建另一个和弦 = group(taskG, taskH, ..) | 任务V

有谁知道如何解决这个挑战？也许我应该改变我的工作流程。

谢谢

https://en.wikipedia.org/wiki/Chord_(peer-to-peer)

我已经研究了 Chord，但我无法准确理解它的作用。它是分布式哈希表的协议，它存储各种键/值以供以后使用？它只是在哈希表中查找给定键的值的一种有效方法吗？

任何帮助（例如基本示例）将不胜感激

我正在努力调试一个我突然遇到的问题，并且会重视一些建议。

我在 Django 中使用 celery 3.1.18，RabbitMQ 作为代理，Oracle 数据库作为后端，即：

CELERY_RESULT_BACKEND='djcelery.backends.database.DatabaseBackend'

我的代码使用和弦，并且已经成功运行了一年左右。

突然之间，和弦都没有在我的 Dev 和 Prod 环境中触发回调，我不知道如何进一步调试。代码没有改变，昨晚，没有改变代码 *我所做的事情让和弦暂时恢复了生命，只是今天早上再次停止工作..表明这是某种资源问题而不是代码问题。

到目前为止，我有：

1. 重新启动运行 rabbitmq-server 和 celery 的主机。
2. 清除所有队列并重复步骤 1。
3. 禁用后端（从 settings.py 中将其注释掉，收到有关禁用后端的错误，然后再次启用后端。

4. 尝试运行显示在文档中工作的和弦的基本命令。该示例挂在外壳上，当您按 CTRL-C 退出时，您会得到：

   from celery import chord from tasks import add, sum callback = tsum.s() header = [add.s(i, i) for i in range(100)] result = chord(header)(callback) result.get()

   ^CTraceback（最后一次调用）：文件“”，第 1 行，文件“/opt/exaboard/eXaboard/lib/python2.7/site-packages/celery/result.py”，第 169 行，get no_ack= no_ack，文件“/opt/exaboard/eXaboard/lib/python2.7/site-packages/celery/backends/base.py”，第 220 行，在 wait_for on_interval() 文件中“/opt/exaboard/eXaboard/lib/python2 .7/site-packages/celery/result.py”，第 181 行，在 maybe_reraise_parent_error node.maybe_reraise() 文件“/opt/exaboard/eXaboard/lib/python2.7/site-packages/celery/result.py”中，第 485 行，maybe_reraise result.maybe_reraise() 文件“/opt/exaboard/eXaboard/lib/python2.7/site-packages/celery/result.py”，第 270 行，如果 self.state 在 states.PROPAGATE_STATES：文件“/opt/exaboard/eXaboard/lib/python2.7/site-packages/celery/result.py”，第 394 行，在状态返回 self.get_task_meta()['status'] 文件“/opt/exaboard/eXaboard/lib/python2.7/site-packages/celery/result.py”，第 339 行，在 _get_task_meta 中返回 self._maybe_set_cache(self .backend.get_task_meta(self.id)) 文件“/opt/exaboard/eXaboard/lib/python2.7/site-packages/celery/backends/base.py”，第 292 行，在 get_task_meta meta = self._get_task_meta_for(task_id ) 文件“/opt/exaboard/eXaboard/lib/python2.7/site-packages/djcelery/backends/database.py”，第 40 行，在 _get_task_meta_for 返回 self.TaskModel._default_manager.get_task(task_id).to_dict() 文件“/opt/exaboard/eXaboard/lib/python2.7/site-packages/djcelery/managers.py”，第 144 行，在 get_task 返回 self.get(task_id=task_id) 文件“/opt/exaboard/eXaboard/lib/ python2.7/site-packages/django/db/models/manager.py”，第 92 行，在 manager_method 返回 getattr(self.get_queryset(), name)(args, *kwargs) 文件“/opt/exaboard/eXaboard/lib/python2.7/site-packages/django/db/models/query.py”，行351，在 get num = len(clone) 文件“/opt/exaboard/eXaboard/lib/python2.7/site-packages/django/db/models/query.py”中，第 122 行，在 __len self._fetch_all()文件“/opt/exaboard/eXaboard/lib/python2.7/site-packages/django/db/models/query.py”，第 966 行，_fetch_all self._result_cache = list(self.iterator()) 文件“/ opt/exaboard/eXaboard/lib/python2.7/site-packages/django/db/models/query.py”，第 211 行，在迭代器中如果连接 [self.db].features.supports_select_related: 文件“/opt/exaboard /eXaboard/lib/python2.7/site-packages/django/db/models/query.py”，第 900 行，在 db @property KeyboardInterruptname)(args, *kwargs) 文件“/opt/exaboard/eXaboard/lib/python2.7/site-packages/django/db/models/query.py”，第 351 行，在 get num = len(clone) 文件中“/opt/exaboard/eXaboard/lib/python2.7/site-packages/django/db/models/query.py”，第 122 行，在 __len self._fetch_all() 文件中“/opt/exaboard/eXaboard/lib/ python2.7/site-packages/django/db/models/query.py”，第 966 行，在 _fetch_all self._result_cache = list(self.iterator()) 文件“/opt/exaboard/eXaboard/lib/python2.7 /site-packages/django/db/models/query.py”，第 211 行，在迭代器中，如果连接 [self.db].features.supports_select_related：文件“/opt/exaboard/eXaboard/lib/python2.7/site- packages/django/db/models/query.py”，第 900 行，在 db @property KeyboardInterruptname)(args, *kwargs) 文件“/opt/exaboard/eXaboard/lib/python2.7/site-packages/django/db/models/query.py”，第 351 行，在 get num = len(clone) 文件中“/opt/exaboard/eXaboard/lib/python2.7/site-packages/django/db/models/query.py”，第 122 行，在 __len self._fetch_all() 文件中“/opt/exaboard/eXaboard/lib/ python2.7/site-packages/django/db/models/query.py”，第 966 行，在 _fetch_all self._result_cache = list(self.iterator()) 文件“/opt/exaboard/eXaboard/lib/python2.7 /site-packages/django/db/models/query.py”，第 211 行，在迭代器中，如果连接 [self.db].features.supports_select_related：文件“/opt/exaboard/eXaboard/lib/python2.7/site- packages/django/db/models/query.py”，第 900 行，在 db @property KeyboardInterruptpy”，第 351 行，在 get num = len(clone) 文件中“/opt/exaboard/eXaboard/lib/python2.7/site-packages/django/db/models/query.py”，第 122 行，在 __len self ._fetch_all() 文件“/opt/exaboard/eXaboard/lib/python2.7/site-packages/django/db/models/query.py”，第 966 行，在 _fetch_all self._result_cache = list(self.iterator() ）文件“/opt/exaboard/eXaboard/lib/python2.7/site-packages/django/db/models/query.py”，第211行，在迭代器中如果连接[self.db].features.supports_select_related：文件“ /opt/exaboard/eXaboard/lib/python2.7/site-packages/django/db/models/query.py”，第 900 行，在 db @property KeyboardInterruptpy”，第 351 行，在 get num = len(clone) 文件中“/opt/exaboard/eXaboard/lib/python2.7/site-packages/django/db/models/query.py”，第 122 行，在 __len self ._fetch_all() 文件“/opt/exaboard/eXaboard/lib/python2.7/site-packages/django/db/models/query.py”，第 966 行，在 _fetch_all self._result_cache = list(self.iterator() ）文件“/opt/exaboard/eXaboard/lib/python2.7/site-packages/django/db/models/query.py”，第211行，在迭代器中如果连接[self.db].features.supports_select_related：文件“ /opt/exaboard/eXaboard/lib/python2.7/site-packages/django/db/models/query.py”，第 900 行，在 db @property KeyboardInterrupt/opt/exaboard/eXaboard/lib/python2.7/site-packages/django/db/models/query.py”，第 966 行，在 _fetch_all self._result_cache = list(self.iterator()) 文件“/opt/ exaboard/eXaboard/lib/python2.7/site-packages/django/db/models/query.py”，第 211 行，在迭代器中如果连接 [self.db].features.supports_select_related：文件“/opt/exaboard/eXaboard /lib/python2.7/site-packages/django/db/models/query.py”，第 900 行，在 db @property KeyboardInterrupt/opt/exaboard/eXaboard/lib/python2.7/site-packages/django/db/models/query.py”，第 966 行，在 _fetch_all self._result_cache = list(self.iterator()) 文件“/opt/ exaboard/eXaboard/lib/python2.7/site-packages/django/db/models/query.py”，第 211 行，在迭代器中如果连接 [self.db].features.supports_select_related：文件“/opt/exaboard/eXaboard /lib/python2.7/site-packages/django/db/models/query.py”，第 900 行，在 db @property KeyboardInterrupt第 900 行，在 db @property KeyboardInterrupt 中第 900 行，在 db @property KeyboardInterrupt 中

任何有关如何进一步调试的建议将不胜感激！

我正在对芹菜任务进行单元测试。我有链式任务也有组，所以产生了和弦。

测试应如下所示：

• 运行 celery 任务（延迟）
• 等待任务和所有子任务
• 断言

我尝试了以下方法：

这会造成死锁，永远重试 chord_unlock。我对任务结果不感兴趣。如何等待所有子任务完成？

我正在尝试实现对等和弦算法。我制作了一个节点数组，每个节点都有一个手指表。我需要能够遍历每个手指表（这是一个哈希表）以找到键值应该去的地方。所以基本上我需要我的fingertable（哈希表）能够被迭代，这样我就可以找到它去哪个节点（它在一个数组中）。我想过将每个手指表（哈希表）放入一个数组列表中，但我无法让它工作。

这可能不是使和弦有效工作的正确方法。因此，如果有更简单的方法来完成这项工作，请告诉我。此外，这不需要是完整的和弦算法（需要添加和删除节点以及所有爵士乐）。只是一个非常基本的和弦版本。

我正在使用 c# 和 System.Drawing.Drawing2D 库来绘制一些规则的几何图形。但是，我无法绘制具有特定中心点以及位于和弦起点和终点的点的椭圆弦。

我正在对几个分布式系统（例如 Chord）进行一些研究，我希望能够仅用我的桌面编写算法并运行分布式系统的模拟。

在模拟中，我需要能够让每个节点独立执行并相互通信，同时手动诱导延迟、丢包、随机崩溃等元素。然后收集数据来估计系统的性能。

经过一番搜索，我发现 SimPy 非常适合我的目标。

SimPy会是适合这项任务的库吗？如果是，对于实施这样的系统有哪些建议/注意事项？