你正在阅读 Celery 3.1 的文档。开发版本文档见： 此处.

celery.task.http

celery.task.http

Webhook task implementation.

exception celery.task.http.InvalidResponseError

The remote server gave an invalid response.

exception celery.task.http.RemoteExecuteError

The remote task gave a custom error.

exception celery.task.http.UnknownStatusError

The remote server gave an unknown status.

class celery.task.http.HttpDispatch(url, method, task_kwargs, **kwargs)

Make task HTTP request and collect the task result.

参数:

• url – The URL to request.
• method – HTTP method used. Currently supported methods are GET and POST.
• task_kwargs – Task keyword arguments.
• logger – Logger used for user/system feedback.

dispatch()

Dispatch callback and return result.

http_headers None

make_request(url, method, params)

Perform HTTP request and return the response.

timeout = 5

user_agent = 'celery/3.1.7'

class celery.task.http.URL(url, dispatcher=None, app=None)

HTTP Callback URL

Supports requesting an URL asynchronously.

参数:

• url – URL to request.
• dispatcher – Class used to dispatch the request. By default this is dispatch().

dispatcher = None

get_async(**kwargs)

post_async(**kwargs)