Aller au contenu principal

Kestra ⇄ Pulse

Intermédiaire ⏱ 15 min kestra · flow yaml · tasks http · 🧪 flow validé en live

Kestra possède le flow YAML déclaratif ; Pulse est le step de flux temps réel, appelé avec deux tasks core io.kestra.plugin.core.http.Request. Exemple du repo : examples/kestra-pulse-bridge/ — l'intégration est un YAML de flow, pas du code.

send_to_pulse (POST /x/order-scoring/in) → wait_for_stream (Pause PT2S) → read_from_pulse (GET /events/order-scoring.score.out) → decide

Lancez-le​

Montez Kestra + Pulse — le examples/orchestrators-compose/ du repo a un profil kestra — puis :

pulse deploy .        # l'app order-scoring (pulse.yaml)

Dans Kestra : ajoutez le secret PULSE_TOKEN (+ pulse_url optionnel), importez flow.yaml, Execute avec l'input amount=2500, puis amount=300. Attendu : escalate, puis auto-approve.

Ce qui est validé — dit précisément​

  • Les deux appels HTTP exacts que font les tasks du flow sont validés en live contre un Pulse --dev : POST K-2500/K-300, le GET renvoie ['K-2500'] — le 300 filtré par le stage streaming.
  • Le serveur Kestra lui-même n'a pas été booté dans la sandbox CI du repo (ses hôtes de téléchargement y sont bloqués). flow.yaml respecte le schéma de flow Kestra — exécutez-le sur n'importe quel Kestra, y compris le profil compose ou Kestra Cloud.

Ensuite​