No project description provided
Project description
Celery service task
Classe permettant d'implémenter une tâche pour un worker Celery spécifique
Usage
# import
from celery_service_task.task import TaskBase
# implémentation d'une tâche simple
class Task(TaskBase):
def task(self, payload: Dict[str, Any], meta: MessageMetadata) -> bool:
print(self.conf) # la configuration est donnée par le worker Celery
print(payload) # le payload est déjà sous forme d'un dictionnaire
print(payload['transaction_id']) # identifiant de la transaction issue du payload
print(meta)
# Initialisation de la classe avec une configuration
t = Task(
conf={'token': 'tk'},
redis=redis_connection,
redis_key=redis_task_key
)
# lance la tâche si l'id de transaction n'est pas déjà enregistré
# Ici la tâche se lance
t.run_task(
payload=payload,
meta=metadata,
t_id=payload['transaction_id']
)
# Ici la tâche est considérée comme un replica
t.run_task(
payload=payload,
meta=metadata,
t_id=payload['transaction_id']
)
Project details
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
Built Distribution
Close
Hashes for celery_service_task-0.8.1.tar.gz
Algorithm | Hash digest | |
---|---|---|
SHA256 | e678c884e94785f67e7bd7d142f58d1617fbb77924b2884856197e61a1e1a70f |
|
MD5 | 4918b0821ba36e66bc919b289c753162 |
|
BLAKE2b-256 | 0ebced59528e6b2622122299c51c4846f08d60350fa983e3ce7aae97abdebb16 |
Close
Hashes for celery_service_task-0.8.1-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | cb2d37275dcce6f2e6cc1aa9e60d1e253c769e25917c604994a72ad7609ab4d0 |
|
MD5 | 990c60f0834a3d2b743164a09548fb66 |
|
BLAKE2b-256 | 7bf1ceffe0ea53db7531a88f6130c084846830d6680cc3d96f7c6e74be603348 |