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

Recommended Posts

mémo céleri / kombu
céleri
mémo gzip
Mémo Raspberry-pi
Mémo Python
mémo graphène
Mémo du flacon
mémo pyenv
Mémo Matplotlib
mémo sed
Mémo Python
Installer Memo
Mémo BeautifulSoup4
mémo networkx
mémo python
mémo Tomcat
mémo de commande
Mémo du générateur.
mémo psycopg2
Mémo Python
Mémo SSH
Mémo: rtl8812
mémo pandas
Mémo Shell
Mémo Python
Mémo Pycharm