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]) -> 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
# Initialisation de la classe avec une configuration
t = Task(
conf={'token': 'tk'},
redis=redis_connection,
redis_key=redis_task_key
)
# simulation d'un payload JSON parsé
payload={'transaction_id': '123', 'hello': 'world'}
# 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,
t_id=payload['transaction_id']
)
# Ici la tâche est considérée comme un replica
t.run_task(
payload=payload,
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.5.0.tar.gz
Algorithm | Hash digest | |
---|---|---|
SHA256 | 1491a9e8e4d1008d3365dee7972aba3919b1798dc9d3ce984ea401bf0cfb30f0 |
|
MD5 | 3937f6fea0f9cabde7b8a99169010474 |
|
BLAKE2b-256 | fb7482cf19d254ac398c76b8183536e919897aa615b921f3c103f31b91d31c9d |
Close
Hashes for celery_service_task-0.5.0-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 95bce7bd5074eec1e0ab3a54330c563874b1f3e93ca29ce85197c68ad334745e |
|
MD5 | ae76453f4a1e8a97a27e6cc1686cafb9 |
|
BLAKE2b-256 | f1a485a1181debea8039dfba75f96c7394833ff66064b651d406c975a63908eb |