Développeurs

À qui s'adresse cette section

Ce que vous pouvez construire

• Pilotez Pulse de manière programmatique, déployez des agents, déclenchez des pipelines, récupérez des événements et approuvez des actions depuis votre code.
• Définissez les pipelines en YAML, versionnez-les dans Git et appliquez-les via l'endpoint d'import, intégré à votre CI.
• Construisez des outils externes qui tournent partout, dans n'importe quel langage, appelables par les agents Pulse via le protocole standard d'invocation d'outils.
• Créez des modèles : packagez un workflow réutilisable en JSON et distribuez-le à vos clients ou à la communauté.
• Ingérez des événements externes via webhooks HTTP avec vérification HMAC, polling de boîtes mail, watchers RSS ou déclencheurs systèmes de fichiers.
• Souscrivez à un flux WebSocket temps réel d'événements, deltas de conversation et changements de statut d'agents.

Démarrage rapide

1curl -X POST http://localhost:9090/api/auth/login \
2  -H "Content-Type: application/json" \
3  -d '{"username":"alice","password":"your-password"}' \
4  | jq -r '.accessToken' > /tmp/token
5
6curl http://localhost:9090/api/pulse/agents \
7  -H "Authorization: Bearer $(cat /tmp/token)" \
8  | jq '.agents[].name'

1# agent.yaml
2name: url-shortener-watcher
3engine: llm
4inputTopic: urls.inbound
5outputTopic: urls.shortened
6systemPrompt: |
7  Extract every URL from the event payload. For each one,
8  call the short_url tool. Return a JSON array of
9  { original, shortened } pairs.
10externalTools: [url-shortener.shorten]

1curl -X POST http://localhost:9090/api/pulse/agents \
2  -H "Authorization: Bearer $(cat /tmp/token)" \
3  -H "Content-Type: application/json" \
4  --data-binary @<(yq -o=json agent.yaml)

1# my_tool.py, minimal external tool server
2from tool_server import Server
3
4srv = Server("my-custom-tool")
5
6@srv.tool()
7async def greet(name: str) -> str:
8    """Greet someone by name."""
9    return f"Hello, {name}!"
10
11srv.run_stdio()

Surface API en un coup d'œil

Pulse expose une surface REST unifiée. L'URL de base par défaut est http://localhost:9090, placez du TLS en frontal pour un accès distant.

Cinq SDKs, une API

Même recette dans chaque onglet : lire un topic Kafka, compter les commandes par client sur une fenêtre d'1 minute, pousser vers une tuile live Power BI.

1from pulse_client import PulseClient, StreamBuilder, windows, aggs
2
3flow = (
4    StreamBuilder("orders-per-customer")
5    .from_topic("orders", source_engine="kafka")
6    .key_by("customer_id")
7    .window(windows.tumbling("1m"), aggregations={"orders": aggs.count()})
8    .to_connector("powerbi", {"powerbi.push.url": "<your-push-url>"})
9)
10
11with PulseClient(base_url="https://pulse.example.com", token="…") as client:
12    client.streams.deploy(flow)

Garanties de stabilité

Guides approfondis