Metadata-Version: 2.1
Name: celery_service_task
Version: 0.9.0
Summary: UNKNOWN
Home-page: UNKNOWN
Author: di-dip-unistra
Author-email: di-dip@unistra.fr
Maintainer: di-dip-unistra
Maintainer-email: di-dip@unistra.fr
License: PSF
Description: # Celery service task
        
        Classe permettant d'implémenter une tâche pour un worker Celery spécifique
        
        ## Usage
        
        ```python
        # 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']
        )
        ```
        
        
Keywords: celery,AMQP,unistra,Université de Strasbourg,serivce,skinos
Platform: UNKNOWN
Description-Content-Type: text/markdown
