o wvXj @sdZddlmZmZddlmZddlmZddlm Z ddl m Z ddl m Z zddlZWn ey9dZYnwe eZd Zd ZGd d d e ZdS) zConsul result store backend. - :class:`ConsulBackend` implements KeyValueStoreBackend to store results in the key-value store of Consul. )absolute_importunicode_literals) bytes_to_str) parse_url)KeyValueStoreBackend)ImproperlyConfigured) get_loggerN) ConsulBackendz^You need to install the python-consul library in order to use the Consul result store backend.csdeZdZdZeZdZdZdZdZfddZ ddZ d d Z d d Z d dZ ddZddZZS)r z'Consul.io K/V store backend for Celery.TN consistentcsBtt|j|i||jdurtt|jdit|jdS)N) superr __init__consulrCONSUL_MISSING_init_from_paramsrurl)selfargskwargs __class__r S/var/www/html/myproject/venv/lib/python3.10/site-packages/celery/backends/consul.pyr )s zConsulBackend.__init__cKs,td||||_tj|||jd|_dS)Nz,Setting on Consul client to connect to %s:%d)hostport consistency)loggerdebugpathrConsulrclient)rhostnamer virtual_hostparamsr r rr1s zConsulBackend._init_from_paramscCs$t|}|jdur |Sd|j|S)Nz{0}/{1})rrformatrkeyr r r_key_to_consul_key8sz ConsulBackend._key_to_consul_keycCsH||}td|z|jj|\}}|dWSty#YdSw)Nz"Trying to fetch key %s from ConsulValue)r&rrrkvget TypeError)rr%_datar r rr)<s    zConsulBackend.getccs|D]}||VqdS)N)r))rkeysr%r r rmgetEszConsulBackend.mgetcCsdt|}||}td||j|jjj|d|jd}td|td||jjj |||dS)aMSet a key in Consul. Before creating the key it will create a session inside Consul where it creates a session with a TTL The key created afterwards will reference to the session's ID. If the session expires it will remove the key so that results can auto expire from the K/V store z.Trying to create Consul session %s with TTL %ddelete)namebehaviorttlzCreated Consul session %szWriting key %s to Consul)r%valueacquire) rr&rrexpiresrsessioncreater(put)rr%r3state session_name session_idr r rsetIs     zConsulBackend.setcCs$||}td||jj|S)NzRemoving key %s from Consul)r&rrrr(r/r$r r rr/ds  zConsulBackend.delete)__name__ __module__ __qualname____doc__rsupports_autoexpirerrrr rr&r)r.r<r/ __classcell__r r rrr s  r )r@ __future__rrkombu.utils.encodingrkombu.utils.urlrcelery.backends.basercelery.exceptionsrcelery.utils.logrr ImportErrorr=r__all__rr r r r rs