http - http 経由でセロリ タスクの呼び出しに http_headers を設定する方法

Question

セロリのクラス HttpDispatch を使用して HTTP 経由でタスク呼び出しを行いたいのですが、Authorization ヘッダーを設定する必要があります。これどうやってするの？

from celery.task.http import HttpDispatch
request = HttpDispatch(
     url='http://example.com/multiply',
     method='GET', {10})
request.dispatch()

Answer 1

プロパティ メソッドをサブクラス化HttpDispatchし、再実装する必要があります。http_headersこのプロパティは の中で使用されHttpDispatchます。

class CustomHttpDispatch(HttpDispatch):

@property
def http_headers(self):
    headers = {
        'User-Agent': self.user_agent,
        'Authorization': 'XXX'}

    return headers