4

Django と Celery を使用して RabbitMQ と通信しています。すべてのタスクを登録し、設定ファイルの CELERY_IMPORTS タプルに入れました。タスクを実行すると、「登録されていません」というエラー メッセージが表示されます。

# tail -f /var/log/celeryd.log 
    . logfile -> /var/log/celeryd.log@INFO
    . events -> OFF
    . beat -> OFF
    . tasks ->
    . apps.contact.tasks.emailContact
    . apps.declaration.tasks.MailChimpSignup
    . apps.questions.tasks.emailQuestionTask
    . queued_storage.tasks.SaveToRemoteTask
[2010-10-19 17:53:44,958: INFO/PoolWorker-1] child process calling self.run()
[2010-10-19 17:53:44,971: WARNING/MainProcess] celery@nolabels.org has started.


[2010-10-19 17:54:03,962: ERROR/MainProcess] Unknown task ignored: "Task of kind 'apps.declaration.tasks.MailChimpSignup' is not registered, please make sure it's imported.": {'retries': 0, 'task': 'apps.declaration.tasks.MailChimpSignup', 'args': [], 'eta': None, 'kwargs': {'email': u'abc123@asdfd.com'}, 'id': '919c6030-70b1-43e6-87f5-907fa0f52c08'}

私のタスク定義は次のようになります。

class MailChimpSignup(Task):
    def run(self, email, **kwargs):
        """
        This will register the declaration signer on mail chimp.
        """
        logger = self.get_logger(**kwargs)
        logger.info("Processed mailchimp signup for %s" % email)
        chimp = chimpy.Connection(settings.MAILCHIMP_API_KEY)

        try:
            chimp.list_member_info(settings.MAILCHIMP_LIST_ID, email)
        except ChimpyException:
            try:
                x = chimp.list_subscribe(
                        settings.MAILCHIMP_LIST_ID,
                        email,
                        {
                        #    'FNAME': self.first_name,
                        #    'LNAME': self.last_name,
                        },
                        email_type='HTML',
                        double_optin = False,
                )
            except ChimpyException:
                return False
        return True
tasks.register(MailChimpSignup)
4

1 に答える 1

2

変。それは正しい名前を持っているようです。

タスクに手動で名前を割り当ててみてください。

@task(name="MailChimpSignup")
def ...
于 2010-10-22T09:30:40.797 に答える