难以跨芹菜更改Python方法签名

Question

这可能是一个Captain Obvious风格的问题，但我觉得我错过了一些东西。

我继承了一个Python WSGI应用程序来创建芹菜任务。它看起来像这样:

#web.py
from bottle import route, run, request, response, abort
import bottle
from project.tasks import process_request
@route('/')
def web():
    url = request.query_string
    process_request.delay(
        url=url,
        path=request.path,
        query=request.query_string,
        cookies=dict(request.cookies),
        headers=dict(request.headers),
        remote_addr=request.remote_addr,
    )

process_request方法如下:

#tasks.py
@celery.task
def process_request(url, path, query, cookies, headers, remote_addr):
    #does some stuff

以上全部工作。我尝试向process_request添加时间戳，所以调用看起来像这样:

#web.py
#imports from above
from datetime import datetime
@route('/')
def web():
    url = request.query_string
    process_request.delay(
        url=url,
        path=request.path,
        query=request.query_string,
        cookies=dict(request.cookies),
        headers=dict(request.headers),
        remote_addr=request.remote_addr,
        s_time=str(datetime.now())
    )

我改变了process_request方法，看起来像:

#tasks.py
@celery.task
def process_request(url, path, query, cookies, headers, remote_addr, s_time):
    #does some stuff

那没有用。请求没有被处理。我检查了celeryd日志文件，发现如下:

[2013-03-26 16:19:03,330: ERROR/MainProcess] Task beacon.tasks.process_request[235f9fa8-1f10-4ee0-a1f9-e389021ea0ad] raised exception: TypeError('process_request() takes exactly 7 non-keyword arguments (6 given)',)
Traceback (most recent call last):
  File "/home/beacon/.virtualenvs/beacon/lib/python2.6/site-packages/celery/task/trace.py", line 228, in trace_task
    R = retval = fun(*args, **kwargs)
  File "/home/beacon/.virtualenvs/beacon/lib/python2.6/site-packages/celery/task/trace.py", line 415, in __protected_call__
    return self.run(*args, **kwargs)
TypeError: process_request() takes exactly 7 non-keyword arguments (6 given)

我不知道我做错了什么。有人有什么想法吗?

Answer 1

这里的问题是，队列中有使用旧方法签名的任务，因为没有时间戳变量。如果没有更多的信息，很难决定你的最佳行动方案。

当前排队的任务是否非常重要?在我看来，解决这个问题最简单、最干净的方法是停止芹菜，通过Redis/RabbitMQ/清空队列，然后重新启动芹菜。此外，这应该是不言而喻的，确保您的任务函数接受新参数作为参数;)

Answer 2

1. 添加新任务，例如process_request_with_stime()，保留旧任务process_request()，替换web()中的调用

2. 部署

3. 待任务process_request()的旧队列作业全部处理完毕后，删除process_request()任务，将process_request_with_stime()重命名为process_request()