a xd) @sdZddlmZddlmZddlmZddlmZddl m Z z ddl Z Wne ybdZ Yn0e e ZdZd ZGd d d eZdS) zConsul result store backend. - :class:`ConsulBackend` implements KeyValueStoreBackend to store results in the key-value store of Consul. ) 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)rz'Consul.io K/V store backend for Celery.TNZ consistentcs>tj|i||jdur$tt|jfit|jdSN)super__init__consulrCONSUL_MISSING_init_from_paramsrurl)selfargskwargs __class__N/var/www/html/Ranjet/env/lib/python3.9/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)loggerdebugpathr ZConsulrclient)rhostnamerZ virtual_hostparamsrrrr .szConsulBackend._init_from_paramscCs&t|}|jdur|S|jd|S)N/)rrrkeyrrr_key_to_consul_key5sz ConsulBackend._key_to_consul_keycCsJ||}td|z|jj|\}}|dWStyDYn0dS)Nz"Trying to fetch key %s from ConsulValue)r"rrrkvget TypeError)rr!_datarrrr%9s    zConsulBackend.getccs|D]}||VqdSr)r%)rkeysr!rrrmgetBszConsulBackend.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)nameZbehaviorZttlzCreated Consul session %szWriting key %s to Consul)r!valueacquire) rr"rrexpiresrsessioncreater$put)rr!r-Z session_nameZ session_idrrrsetFs      zConsulBackend.setcCs$||}td||jj|S)NzRemoving key %s from Consul)r"rrrr$r+r rrrr+as  zConsulBackend.delete)__name__ __module__ __qualname____doc__r Zsupports_autoexpirerrrr r r"r%r*r3r+ __classcell__rrrrrs  r)r7Zkombu.utils.encodingrZkombu.utils.urlrZcelery.backends.baserZcelery.exceptionsrZcelery.utils.logrr ImportErrorr4r__all__r rrrrrs