mémo céleri / kombu

kombu.utils.symbol_by_name()

Importez le module spécifié par la chaîne de caractères

>>> import kombu.utils
>>> kombu.utils.symbol_by_name('argparse')
<module 'argparse' from '/Users/sximada/.anyenv/envs/pyenv/versions/3.4.2/lib/python3.4/argparse.py'>

Utilisez un point-virgule pour obtenir l'objet à l'intérieur du module

>>> kombu.utils.symbol_by_name('argparse:ArgumentParser')
<class 'argparse.ArgumentParser'>

celery.utils.instantiate()

Instanciez l'objet spécifié par la chaîne

>>> import celery.utils
>>> celery.utils.instantiate('argparse:ArgumentParser', description='test')
ArgumentParser(prog='', usage=None, description='test', formatter_class=<class 'argparse.HelpFormatter'>, conflict_handler='error', add_help=True)

kombu.utils.cached_property()

cache de propriété. C'est comme reify.

Pool de connexion

Lors de l'utilisation de redis, redis.ConnectionPool () est utilisé par défaut. Par conséquent, la synchronisation de connexion est créée par make_connection () s'il n'y a pas assez de connexions à la synchronisation de pool.get_connetion () lors de l'acquisition de la connexion de redis.

Flux de reprise d'application

1. Spécifiez le nom de l'objet Celery () (spécifié par --app) et la commande celery (premier argument) dans les paramètres CLI.
2. La propriété app est définie dans le constructeur de celery.bin.cellery.CelleryCommand ()
3. Récupérez la commande correspondant au premier argument dans celery.bin.cellery.CelleryCommand.execute () et passez l'objet app lors de l'instanciation