python - 使用 deferred.defer 任务发布到数据存储时出现问题

Question

我正在尝试使用 Python 在 Google App Engine 上执行此操作:

def add_to_db(person):
     a = PersonDb(key_name = person)
     # get some data
     data1 = a.name
     data2 = a.age
     a.put()

for person in people:
    deferred.defer(add_to_db, person, _queue="myque")

当我通过 cron 作业运行上述代码时，它不起作用。文件执行时没有错误，任务(“People”列表中有 200 个字符串)被正确添加到队列中并正确地通过。但数据库 PersonDb 没有更新。我知道这个函数可以工作(上面是简化的)，因为它可以工作:

for person in people:
     add_to_db(person)

以上两行代码有效，并且数据库得到更新，但我需要将其作为延迟任务运行。有什么建议吗？

更新:我在日志中看到以下内容: 文件“C:\Program Files\Google\google_appengine\google\appengine\ext\deferred\deferred.py”，第 129 行，运行中 引发永久任务失败(e) PermanentTaskFailure:“模块”对象没有属性“add_to_db”

Answer 1

发生这种情况可能是因为您尝试推迟的函数 (add_to_db) 是在请求​​处理程序中定义的。将 add_to_db 移动到另一个模块(不同的 python 文件)并从那里导入它(from myfuncs import add_to_db)。

延迟 article 的限制部分中提到了此限制.