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.7.0.tar.gz
Algorithm | Hash digest | |
---|---|---|
SHA256 | ddfc5ca5ca0b6a5cb93ff8b4b8f27ca116476d47b6a751ad33561dbf3ba194c2 |
|
MD5 | 775af44502a1356ac6ddd7efdfd7d27e |
|
BLAKE2b-256 | 84fa3180d7561845694fb0235b502fd19a4352781dbf75bd0cc2b528d60f99d3 |
Close
Hashes for celery_service_task-0.7.0-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | e683fce4955f8b185e492723d366627cbf7bda6e763144f31085dec8e683f07b |
|
MD5 | 7f1f4821c01733ac2a088d3039df7e78 |
|
BLAKE2b-256 | f3137951587af700960459368d1a347cca25cee493f33c49355f89d42f3b20ba |