[PYTHON] Sellerie / Kombu Memo

kombu.utils.symbol_by_name()

Importieren Sie das durch die Zeichenfolge angegebene Modul

>>> 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'>

Verwenden Sie ein Semikolon, um das Objekt in das Modul aufzunehmen

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

celery.utils.instantiate()

Instanziieren Sie das durch die Zeichenfolge angegebene Objekt

>>> 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()

Eigenschafts-Cache. Es fühlt sich an wie Reify.

Verbindungspool

Bei Verwendung von redis wird standardmäßig redis.ConnectionPool () verwendet. Daher wird das Verbindungs-Timing von make_connection () erstellt, wenn zum Zeitpunkt von pool.get_connetion () beim Erwerb der Verbindung von redis nicht genügend Verbindungen vorhanden sind.

Ablauf der Anwendungsübernahme

1. Geben Sie den Celery () -Objektnamen (angegeben durch --app) und den Selleriebefehl (erstes Argument) in den CLI-Parametern an
2. Die App-Eigenschaft wird im Konstruktor von celery.bin.celery.CeleryCommand () festgelegt.
3. Rufen Sie den Befehl ab, der dem ersten Argument in celery.bin.celery.CeleryCommand.execute () entspricht, und übergeben Sie das App-Objekt beim Instanziieren