个人中心
文章发布
退出
作者热门文章
- android - 多次调用 OnPrimaryClipChangedListener
- android - 无法更新 RecyclerView 中的 TextView 字段
- android.database.CursorIndexOutOfBoundsException : Index 0 requested, 光标大小为 0
- android - 使用 AppCompat 时，我们是否需要明确指定其 UI 组件(Spinner、EditText)颜色
25
4
执行异步任务时 celery 引发异常
#case where error is thrown
send_registration_email.delay("test", "test@gmail.com", {})
当我通过省略 celery 执行代码时，不会出现此错误
#case where code is executed correctly
send_registration_email("test", "test@gmail.com", {})
如何使用 celery 执行异步任务，从而消除此错误？
[2015-10-12 14:50:57,176: ERROR/MainProcess] Task tasks.core.email.send_registration_email[5f96bee3-9df7-42ce-b726-c7086e82b954] raised unexpected: NameError("global name 'Mailer' is not defined",)
Traceback (most recent call last):
File "/usr/local/lib/python2.7/site-packages/celery/app/trace.py", line 240, in trace_task
R = retval = fun(*args, **kwargs)
File "/usr/local/lib/python2.7/site-packages/celery/app/trace.py", line 438, in __protected_call__
return self.run(*args, **kwargs)
File "/srv/www/compare/htdocs/tasks/core/email.py", line 6, in send_registration_email
@shared_task
NameError: global name 'Mailer' is not defined
# email.py
from __future__ import absolute_import
from celery import shared_task
from utilities.helpers.mailer import Mailer
@shared_task
def send_registration_email(email_type="", recipient="", data={}):
Mailer.send_email(email_type, recipient, data)
# mailer.py
from __future__ import absolute_import
from django.core.mail.message import EmailMultiAlternatives
from django.template.loader import get_template
class Mailer():
@staticmethod
def send_email(email_type="", recipient="", data={}):
try:
email = Mailer.create_email(email_type, recipient, data)
email.send()
return True
except Exception as e:
return False
@classmethod
def create_email(self, email_type, recipient, data):
subject = ""
message = ""
sender_email = "mailgun@xxx.mailgun.org"
if email_type == "test":
subject = "Test subject"
content_html = "<html><body><h1>Test</h1></body></html>"
email = EmailMultiAlternatives(subject, None, sender_email, [recipient])
email.attach_alternative(content_html, "text/html")
return email
最佳答案
您需要重新启动工作器才能看到工作器实例中反射(reflect)的文件更改。 Celery 不会监视文件更改，因此如果您在工作线程运行时更改任何文件，则需要重新启动工作线程。
出于开发目的，可以使用auto reloading来回避这个问题。特点:
When auto-reload is enabled the worker starts an additional thread that watches for changes in the file system. New modules are imported, and already imported modules are reloaded whenever a change is detected, and if the prefork pool is used the child processes will finish the work they are doing and exit, so that they can be replaced by fresh processes effectively reloading the code.
这是一项实验性功能，只能在开发环境中使用
关于python - 调用异步任务 celery 时引发异常 : "NameError: global name * is not defined"，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/33081993/
25
4
0
我正在使用 SharePoint Online 并使用 Windows Azure 托管访问 SPO 的进程。 我们已将启动任务添加到 Azure 角色以安装 http://www.microsoft
我有一个函数，它获取包含时间的源文件(csv 文件)，读取它，然后按顺序对行进行排序并将它们写入目标文件中。但是，如果源 csv 文件不存在，我需要引发 FileNotFoundError。我之前曾引
我试图在目录不存在时引发错误，然后再打开该目录中的文件。根据this response我应该为我的问题使用最具体的异常构造函数，我认为它是 NotADirectoryError。但是运行下面的代码我得
在编码/开发生命的一天或另一天，我们确实遇到了这个特殊的情况，这是最常见的异常(exception)之一。我的问题是关于的而不是。为什么(我知道当我们尝试访问实际上指向null的引用变量的属性时会引发
我想知道在 python 中是否可以在一个 except block 中引发异常并在稍后的 except block 中捕获它。我相信其他一些语言默认会这样做。 这是它的样子" try: som
我有以下代码: br = mechanize.Browser() br._factory.is_html = True br.form = mechanize._form.ParseString(''
我刚刚发现，如果您有一个引发 TOO_MANY_ROWS 异常的 SELECT INTO，该变量仍会从查询检索到的第一条记录中分配值。这是预期的行为吗？ 这是我的例子: for co in my_cu
当 SSH 显示 WARNING: REMOTE HOST IDENTIFICATION HAS CHANGED! 我知道当您重新安装远程服务器时会发生这种情况，但我尝试列出 其他原因 . 我知道如何
我有一个枚举和一个 EnumMap . 我将 map 放入一个类中以隐藏“字节”值。所以我有一个set(Parameter, int)和set(Parameter, boolean)方法。 publi
在什么情况下会redis-py引发以下 AttributeError 异常？ redis-py 不是设计来引发仅基于 redis.exceptions.RedisError 的异常吗？ 什么是合理的处
可悲的是，对此异常的引用通常具有异国情调，并且可能发生在您例如通过 Assembly.GetTypes() 枚举类型- 举个例子，它发生在我们的一个部署上，但同一组程序集在集成服务器上运行良好。 为了
我正在为 Android 下的特定平板电脑克隆一个存储库并获取源代码，我必须执行一个 python 脚本。当我执行它时，我收到此错误消息: Traceback (most recent call la
首先，执行此操作(在运行 4.4.2 的 Nexus 5 上测试): 将 PRIORITY_LOW 通知传递给 Service.startForeground()。 观察通知不显示在状态栏中。 使用相
我尝试使用 AppEngine 的 python 模块 api 来获取使用基本缩放的模块的实例数。在我模块的 yaml 文件中，我明确设置了 max_instances 参数。我希望 get_num_
当我如下运行我的 spark python 代码时: import pyspark conf = (pyspark.SparkConf() .setMaster("local")
在我的系统上，一段适用于 Python 2 的代码不适用于 Python 3。 f = open("plotwidget.svg") svgData = f.read() xml_stream = Q
我是 PHP 和 SQL 的新手，但我正在创建一个登录系统。我遇到的问题是: You have an error in your SQL syntax; check the manual that c
我有一个使用 ebaysdk 库的 python 代码，当我运行代码并输入关键字进行搜索时，我得到了这个错误。 Traceback (most recent call last): File "eba
当我将表单数据发送到我的 Flask 应用程序时，出现以下错误。它说它将使用 UTF-8 编码，但语言环境已经是 UTF-8。这个错误是什么意思？ /home/.virtualenvs/project
在python2.7中，跟随pympler example : from anotherfile import somefunction, somecustomclass from os import
我是一名优秀的程序员,十分优秀！