草庐IT

kue-scheduler

全部标签

node.js - 带有 kue 的 NodeJS 应用程序从不从 0 开始

我有一个使用kue执行长时间运行操作的nodeJSapi。虽然,一旦我关闭应用程序并重新启动它,所有以前的作业仍然存在。移除它们不会将Redis计数器重置为0。仅从任何状态移除它们:事件、非事件、失败、完成或延迟。这是我的kue声明:varkue=require('kue'),queue=kue.createQueue()每次调用某个api端点时,我都会执行以下操作://enqueueanewjobprocessfordataanalysisvardaJob=queue.create('job1',{title:'jobtobecompleted'}).removeOnComplete

python - 我在 python 应用程序中使用的 celery.scheduler 不起作用

我在运行周期性任务时遇到问题?当我运行代码celeryworker-Atasks--loglevel=debug.看起来不错,但在终端中出现此消息后它停止并且不执行任何操作:[2019-07-1022:29:21,149:DEBUG/MainProcess]basic.qos:prefetch_count->16fromceleryimportCeleryfromcelery.schedulesimportcrontabfromdatetimeimportdate,timedeltafromconfigimport*fromemailimportencodersfromemail.mi

javascript - Node 重启时丢失所有 Kue/Redis 作业

我正在查看在Node中实现作业队列的一些选项,并偶然发现了使用Redis的Kue。是否因为作业存储在Redis中,所以如果我重新启动Node或服务器,所有作业都会丢失? 最佳答案 Redis是内存中持久存储。它在conf文件中配置的一定时间后将数据存储在键值对中。因此,即使服务器或Node出现故障或重新启动,您提交的数据也将持久存在。 关于javascript-Node重启时丢失所有Kue/Redis作业,我们在StackOverflow上找到一个类似的问题:

python-3.x - 从 Celery Scheduler 检索已执行的任务?

我使用的是Python3.6.6,以及最新版本的Redis、Celery、CeleryBeat和CeleryRedbeat。我目前正在使用Celeryredbeat来安排任务的定期执行。一切正常,但我没有看到链接调度程序执行的任务的明显方法,因此我可以检索它们的结果。例如,调度程序运行的任务在Redis中显示为“celery-task-meta-(task-id)”。在任务或调度程序中,我看不到任何链接。我知道我可以指定“选项”参数并提供一个参数字典来修改任务执行,但是没有什么特别的。我正在寻找一种方法来将“celery-task-meta”更改为与调度程序名称对应的值,或者将已完成的

swift 2.0 : Schedule background task to upload failed product uploads

我正在开发一个将产品(JSON)上传到服务器的应用程序。现在,每个产品对象都包含许多图像。如果与该产品关联的所有图像都已上传,则该产品仅上传到服务器。如果产品的所有图片都没有上传,产品应该以“PENDING”状态存储在移动数据库中(我使用的是Realm)。我想要一个后台任务来定期(每15分钟)检查数据库中是否存在此类失败的产品上传,检查与该产品关联的所有图像现在是否已上传并将产品排队等待上传到服务器。此后台任务将仅在应用程序运行时执行,否则不会执行。该任务应在启动时启动并在应用程序关闭时终止。我找到了一些相关的解决方案(与NSTimer和iOS中的后台模式等相关),但没有直接解决我的问

java - JMeter Scheduler 中的开始时间和结束时间

我正在使用JMeter2.5.1版,我想为我的线程组设置一个调度程序。我为调度程序字段设置了以下值:StartTime=2011/12/1311:30:00EndTime=2011/12/1311:32:00Duration(seconds)=3Startupdelay(seconds)=5我的线程在延迟5秒后启动,并持续运行最多3秒。但是我看不到开始时间和结束时间对我的线程有任何影响。请告诉我这些字段在线程运行过程中的作用。 最佳答案 根据Jmeterdocumentation,DelayoverridesStartTime,an

python - Airflow scheduler 是否有可能在开始下一天之前先完成前一天的周期?

现在,我的DAG中的节点会在该DAG的其余节点完成之前继续执行第二天的任务。有没有办法让它在进入第二天的DAG周期之前等待DAG的其余部分完成?(我确实将depends_on_past设为true,但在这种情况下不起作用)我的DAG看起来像这样:OlVO->O->O->O->O此外,dag的TreeView图片] 最佳答案 这个答案可能有点晚了,但我遇到了同样的问题,我解决它的方法是在每个dag中添加两个额外的任务。开头为“Previous”,结尾为“Complete”。上一个任务是监视上一个作业的外部任务传感器。Complete只

python - 我在 Django 应用程序中的哪里注册 rq-scheduler 作业?

我想使用django_rq和rq-scheduler进行离线任务,但我不确定在哪里调用rq-scheduler安排重复任务的能力。现在,我已将我的日程安排添加到我的应用程序中的tasks.py模块,并将其导入到__init__.py中。不过,必须有更好的方法来做到这一点,对吗?提前致谢。 最佳答案 我创建了一个自定义管理命令,它修改并替换了django_rq中包含的rqscheduler命令。此处提供了一个示例:https://github.com/rq/rq-scheduler/issues/51#issuecomment-362

SpringBoot项目中@Scheduled定时任务配置线程池

SpringBoot项目中定时任务配置线程池1在启动类上加入@EnableScheduling注解2通过实现SchedulingConfigurer接口来将定时线程池放入3编写定时任务使用spring的定时器@Scheduled的话,因为@Scheduled默认是单线程执行的,所以在需要的时候,我们可以设置一个线程池去执行定时任务。1在启动类上加入@EnableScheduling注解importorg.springframework.boot.autoconfigure.SpringBootApplication;importorg.springframework.scheduling.an

ios - 向 iTunes 商店发送数据时出错 "scheduling restart shortly"

在TestFlight上上传应用程序时。错误显示“将数据发送到iTunes商店时出错”“正在安排重新启动”。此外,它不使用AppLoader上传。 最佳答案 等待它自动重新启动此过程并上传您的应用。我遇到了同样的问题。我只是在同一个窗口中等待。 关于ios-向iTunes商店发送数据时出错"schedulingrestartshortly",我们在StackOverflow上找到一个类似的问题: https://stackoverflow.com/questi