我有一个如下创建装饰器，

在上面的代码中，如果我直接使用装饰器@periodic_task，那么当它到达指定的时间时，函数 delete_inactive_task() 会被正确触发，

但是当我使用 schedule_stop_dec 和 sc_status = True 然后在日志中我得到以下消息，好像它被触发但在实际日志中如果我检查'功能触发'消息不存在

请让我知道如何使用指定的标志控制 #periodic_task 装饰器。

我已经使用示例“如何在 python 2.6 中执行条件装饰器”尝试了上面的示例

这是我开始 celery 定期任务的方式。首先我执行这个命令：

之后这个命令：

在两个不同的终端选项卡上执行这两个命令后，我的 celery beat 周期性任务开始运行。如果我不运行所描述的命令之一，我的定期任务将不会运行。我的问题是：有什么方法可以使用单个命令启动 celery，或者使用 runserver 命令更好？

我怎样才能完成运行 Django Celery 任务，使其仅在周一至周五运行，并且仅在美国东部标准时间上午 9 点至下午 5 点运行？

celery.py

我应该向 crontab() 添加哪些参数以使其在那些日子和仅在这些小时之间运行？

我正在使用 AWS Lambda（每小时由 Cloudwatch 规则触发）来触发 EMR 集群的创建以执行作业。EMR 集群完成其步骤后，将结果文件写入 S3 存储桶。关键路径是一天中的小时

我想发出一些警报，以防 EMR 作业由于某种原因未能在该小时内创建 result.txt。

我已经在 Lambda 调用计数和 lambda 错误计数上发出了一些警报，但我没有找到合适的警报来测试 EMR 是否确实正确地完成了它的工作。

请注意，Lambda 每小时每 3 分钟触发一次，大约需要 15 分钟才能完成。一个好的解决方案是创建一个其他 Lambda，每 30 分钟触发一次，并检查存储桶中是否存在正确的密钥？如果没有，那么将一些日志写入 cloudwatch，我可以监控并使用它们来创建警报？

我还有什么其他方法可以实现这种警报？

我正在尝试使用 GCMTaskManager 安排大约每 30 分钟运行一次的定期任务。当它运行时，它会对 APP 中的一些内部数据进行“更新”。

我已经初步运行了它，并且可以使用 中的LOG命令看到OnRunTask该任务根据需要触发。我让它运行（至少根据我在OnRunTask触发时填充的日志。

我有两个问题我无法确定是否可以完成......

• 有没有办法查看在下一次火灾之前“还剩”多少时间OnRunTask......或者......大约接下来应该运行什么“时间”？例如，如果 PeriodTask... 有 30 分钟，而 18 分钟已经过去，我们能否以编程方式看到还剩 12 分钟？

• 我有一个内部“按钮”来手动触发 APPS 更新。如果用户点击了这个，我想从那个点“重新启动”PeriodicTask 计时器。也就是说，如果OnRunTask假设 30 分钟在大约 12 分钟内触发，并且用户手动点击 UPDATE，我希望OnRunTask现在从按下按钮后的 30 分钟重新启动。这可以做到吗？

谢谢

皮特

我有一个应用程序，它MainActivity有一个从按钮点击调用的方法（称为doUpdate()）。这使用MainActivity的公共变量来访问数据库，执行一些更新，并更新一些记录。这很好用。

我们现在还需要使用 a 来自动化它PeriodicTask。

我创建了一个GCMTaskManager服务如下：

在我的 MainActivity 中onCreate()，我设置PeriodicTask如下：

通过查看日志，我知道onRunTask()火灾会如我所愿定期发生。

现在我需要调用我的MainActivity方法doUpdate()...... 因为这个方法是声明的PUBLIC VOID而不是声明STATIC的，所以我不能从服务中调用它doRunTask()。如果我尝试将其设为 a STATIC PUBLIC VOID，则MainActivity无法根据内部处理步骤的需要正确访问变量。

我该如何解决这个问题......有什么建议吗？

你认为可以在django中使用asyncio每n秒运行一次任务，这样主进程就不会被阻塞吗？

例如，在控制台中每 5 分钟打印一次，例如：

循环运行时，django 似乎会停止工作。即使这可以在开发中工作，当站点在 apache 或 gunicorn 上运行时它会如何表现？

我想在每年 5 月 8 日到 5 月 12 日之间发送一次通知。

但是我坚持与不同年份相比，这导致每次用户启动应用程序或重新启动时都会发送通知，如果时间在 5 月 8 日到 5 月 12 日之间。

这让我很困惑，有人可以教我如何解决这个问题，我将不胜感激。

提前致谢。

我的清单：

我的主要活动将保存boolean和year：

我的 PlayReceiver：这行代码if ( neverSend || !(firstYear == nextYear)){让我很困惑

我的 AlarmInitReceiver：

我目前正在尝试每 10 毫秒调用一次函数来从传感器获取数据。

基本上我是从 gpio 中断触发回调，但我更换了传感器，而我目前使用的传感器没有 INT 引脚来驱动回调。

所以我的目标是具有相同的行为，但具有由计时器生成的内部中断。

我从这个主题尝试了这个

但是当我运行它时，我可以看到计时器并不是很精确，并且它随着时间的推移而推导，正如你所看到的。

所以计时器每 10 毫秒推导 0.2 毫秒，这在几秒钟后是一个很大的偏差。

我知道 python 并不是真正为“实时”而设计的，但我认为应该有办法做到这一点。

如果有人已经不得不用 python 处理时间限制，我很乐意得到一些建议。

谢谢。

我创建了一个基于类的定期任务，使用 djcelery 向客户端发送电子邮件。当从 shell 调用任务时，它正在执行操作并发送电子邮件，但是在使用 crontab 时，我将 KeyError 设为“Schedule.tasks.run”。我添加了以下设置并创建了任务：

设置.py

错误信息：

邮件正文的完整内容是：

回溯（最近一次通话最后）：

文件“/home/s/proj/env/lib/python3.5/site-packages/celery/worker/consumer.py”，第 465 行，on_task_received strategy[type_](message, body, KeyError: 'schedules.tasks 。跑'