问题标签 [django-rq]

For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.

0 投票
1 回答
338 浏览

django - 调度异步电子邮件作业失败并出现错误 SMTPAuthenticationError: (535, '5.7.3 Authentication unsuccessful')

我正在尝试安排异步电子邮件作业。我使用django-rq作为排队机制。我尝试了许多修复,例如更改密码、确保密码正确等。我可以通过 REPL 手动发送 SMTP。

更新#1:据我所知,工作人员正在正确获取设置。该作业正确地获取了正确的值settings.DEFAULT_FROM_EMAIL并将正确的电子邮件地址设置为 send_mail 的 arg。

以下代码成功运行(没有 django-rq):

而下面的代码会生成一个 SMTP 身份验证错误(向下追溯):

追溯:

为什么抛出异常,我该如何解决?

0 投票
0 回答
740 浏览

python - Django rq worker 正确设置通过 django settngs

我有一个运行良好的 django 项目。我需要一个 rq 工人来做一份工作。我有一个 redis 服务器正在运行。

Whis 是我的 worker.py 文件:

我使用以下命令行从我的 ubuntu 终端运行工作程序: /opt/crm/env/bin/python /opt/crm/ak/ak/worker.py

工人开始很好。

我给它的工作是从数据库中获取数据并将数据写入 excel 文件,但我收到以下错误:

谁能告诉我可能出了什么问题?

0 投票
1 回答
1181 浏览

python - Django-RQ:如何调用函数?

我正在将一个项目迁移到Django并喜欢使用该django-rq模块。
但是,我被困在这里放什么:

怎么打电话func?这可以是一个字符串path.file.function吗?
该函数是否需要驻留在同一个文件中?

0 投票
1 回答
882 浏览

python - RQ Timeout 不会杀死多线程作业

我在使用 python RQ 运行多线程任务时遇到问题(在 v0.5.6 和 v0.6.0 上测试)。

考虑以下代码,作为我想要实现的简化版本:

东西.py

主文件

执行时main.py(当 rqworker 在后台运行时),作业在 5 秒内按超时中断。

问题是,当我设置一个包含线程/s 的任务时MyThing().hello_task,线程永远运行,当 5 秒超时结束时没有任何反应。

如何使用 RQ 运行多线程任务,这样超时会杀死任务、它的儿子、孙子和他们的妻子?

0 投票
1 回答
354 浏览

django - Django rq 做批量数据库插入

如何将运行很长时间的函数排入队列?

我想做以下事情:

def batch_insert(data): rows.append(MyModel(*data)) if len(rows) > 1000: MyModel.objects.bulk_create(rows)

0 投票
1 回答
424 浏览

python - Django rq 调度程序不能将相同的任务排入队列两次

我正在使用rq 调度程序。我想提醒用户在 2 分钟和 10 分钟后验证他们的电子邮件。所以我使用 post_save 信号来安排这些任务。我已经设置了这样的任务:

问题是:我在 2 分钟后收到一封邮件,但在 10 分钟后没有收到第二封邮件。任何帮助表示赞赏。

0 投票
0 回答
319 浏览

django - Django-rq-scheduler:使用来自 django-admin 的参数调用函数

我们正在使用 django 1.10、django-rq、django-rq-scheduler。

在 django 管理员中,可以设置一个可调用函数,但是如何将特定的参数值发送到该函数(例如,在屏幕截图中调用 dir_listener.dir_scanner.scan_all_directories(3, 'kuku') )?

django admin rq-调度程序

谢谢

0 投票
1 回答
105 浏览

django - Django-RQ + Braintree:提交结算

我已经阅读了这个 stackoverflow Q&A但它并没有解决我的问题。

在我的场景中,我submit_transaction_for_settlement(transaction_id)使用优秀的包将函数 () 推送到 redis 队列django-rq。此功能的工作是提交交易以进行结算。

在沙箱中,每当执行此功能时,我都会收到相同的错误:AttributeError: type object 'Configuration' has no attribute 'environment'.

我尝试了关于我的函数内部agf的建议instantiate a new gateway for each transaction,但没有奏效!

也许这与redis队列的环境或worker环境有关?

0 投票
1 回答
1031 浏览

python - NGINX/Gunicorn/Django-RQ:如何将每个 rq-worker 记录到不同的文件中

我们使用 NGINX + Gunicorn + Django + RQ 的架构,有几个 rq-workers。我们使用基本的 Django 日志记录设置(如下),带有翻转和最大文件大小,但是:

  1. 创建的文件有时非常小 -几个字节而不是定义的 2MB
  2. 数字翻转文件与定义的不同。

问题:
一个。知道为什么实际文件创建数量和大小与定义不同吗?
湾。是否可以让每个 django rq-worker 使用翻转和最大文件大小策略记录到不同的文件?

我们的日志设置:

谢谢

0 投票
0 回答
238 浏览

python - Python Django + RQ:作业正在执行但跳过所有 if/elif 块

我不知道这里发生了什么。我有一个简单的 django 网站,我在其中登录并填写包含一些信息(设备地址、电源插座 1/2、开/关)的基本表格。当我提交表单时,RQ 将此任务(使用请求向 URL 发出 HTTP GET 请求)提交到队列中并执行。我在函数的末尾放了一个返回“作业完成”,我看到作业正在完成,结果是“作业完成”。因此该函数正在执行,但由于某种原因,它跳过了所有 if/elif 块。查看 django-rq 仪表板和工作控制台输出,看起来参数传递正确。如果我将函数复制/粘贴到 python 窗口中,它会在我传递相同的参数时成功运行。

视图.py

任务.py

工人输出: