task-queue

0热度

2回答

在谷歌应用程序引擎中，当您将任务添加到同一个推送任务队列时，它们是否会按照时间顺序排列？或者是否有可能一个任务可以在另一个任务之前执行，尽管它最后被添加了？（这是假设他们正在使用相同的队列）。

0热度

1回答

我是新来的Python和芹菜，Redis的，所以请纠正我，如果我的理解是不正确的芹菜储存任务结果。我一直在调试代码库一种结构类似 - TaskClass - >芹菜任务 HandlerClass1, HandlerClass2 - >这些Python类扩展对象类应用程序创建TaskClass说dumyTask实例和dumyTask创建芹菜子任务（我相信这些子任务是唯一的）说dumySubTas

0热度

2回答

保证在GAE中只添加一个任务推送队列一次

我想确保任务—特别是在单个实体上运行的任务—最多被添加到推送队列中，直到这样一个时间之前添加的任务已完成。然后，我应该可以再次为同一个实体—添加相同的任务—。一个简单的例子是，更新实体答：我希望能够到一个任务：添加任务X到实体A更新到推队列。虽然任务X位于实体A的队列中，但为实体A添加任务X的所有其他尝试都会失败。一旦完成，我要再次可以添加任务X为实体A. 简单的解决方案似乎是使用结合任务

1热度

2回答

在AppEngine标准环境中使用Java创建线程

我是Google Cloud Platform中的新成员。我正在使用AppEngine标准环境。我需要在java中创建主题，但我认为这是不可能的，是吗？这里的情况是：我需要创建订阅供用户使用。有三个数据库名称为d1, d2, d3。每当用户发送请求时，Java会创建三个线程，每个数据库一个线程。例如t1代表d1，t2代表d2和t3代表d3。这些线程必须异步运行才能获得更好的性能，之后将这3

1热度

3回答

Google App Engine - 队列结束时的事件

我开始构建批量上传工具，并试图解决如何完成其中一项要求。这个想法是，用户将上传一个CSV文件，该工具将解析它，并将CSV的每一行发送到任务队列作为要运行的任务。然后，一旦完成了与该特定CSV文件有关的所有任务，就会向用户发送摘要报告。我使用的是Google App Engine，过去我使用标准任务队列来处理任务。但是，使用标准任务队列时，无法知道队列何时完成，因此不会触发事件触发报告生成，

0热度

1回答

使用芹菜分配数学处理

介绍嗨，我是超新于一般，所以我有一个问题，可能是相当幼稚的芹菜和任务队列。我想要一个相当大的.csv文件（将其转换为pandas DataFrame）并在所有列对上对其执行皮尔逊测试（统计数学函数）。大约需要9分钟到一个核心，我们有数百个.csv文件！所以我想在我们的3台服务器集群上的所有内核之间划分这个处理。这里有一个原型的我的代码迄今.... from celery import Cel

0热度

1回答

为什么队列上的GAE任务运行得比指定的更频繁？

我有一个队列定义如下： .... <queue> <name>sendMailsBatch</name> <rate>1/m</rate> <max-concurrent-requests>1</max-concurrent-requests> <retry-parameters> <min-backoff-seconds>70</min-ba

2热度

1回答

谷歌AppEngine无法推迟sendmail作业默认taskqueue，收到未经授权的发件人错误

您好，我试图推迟通过sendmail发送邮件。能够发送邮件没有问题。只要我尝试deferred.defer(send_invitation,recipient)，它就停止工作。我可以看到任务重试最大允许的极限，以及日志显示： File "/base/data/home/runtimes/python27/python27_lib/versions/1/google/appengine/api

0热度

2回答

golang：防止同级错误重置连接的策略

该程序同时产生许多goroutines（getStock），我相信这会导致远程服务器立即丢弃连接。我不是想创建一个DOS，但我仍然想要积极获取数据而不会发生“连接重置”错误。什么是一些策略最多只有N（例如20）同时连接？在golang Http客户端中有GET请求的内置队列吗？我还在学习，如果对这种类型的代码有更好的设计模式，那将是很好的理解。输出 $ go run s1w.go sl(si

3热度

1回答

有没有办法使用App Engine Java运行时动态地设置任务的目标？</p> <pre><code>task = taskqueue.add( url='/update_counter', target='worker', params={'amount': amount}) </code></pre> <p>有没有办法在执行此操作：

当排队与App Engine的Python运行一个后台任务，你可以specify a target for the queue将发送任务，要在一个特定的服务，版本或实例上运行Java的？文档mentions the target parameter但未显示如何使用它的示例。 Queue.add方法没有target的选项。 TaskOptions类别没有任何类似target的任何东西。 This q