Code Python (sortie)
Consomme le flux d'entrée avec du code Python (pandas). La brick reçoit le
DataFrame dans la variable df et vous en faites ce que vous voulez : export
vers un service maison, appel d'API, écriture libre… Elle n'a pas de port de
sortie.
Contrat
Le code s'écrit façon notebook : pas de classe ni de fonction à définir.
La variable df contient une copie du DataFrame d'entrée : le
modifier n'affecte pas le reste du pipeline.
Le namespace d'exécution expose :
| Nom | Description |
|---|---|
df | Le DataFrame d'entrée (copie). |
pd | pandas. |
np / numpy | NumPy. |
log(msg) | Trace un message dans les logs d'exécution. |
log_warning(msg) | Trace un avertissement. |
En cas d'erreur, le message pointe la ligne fautive du snippet avec son extrait.
Exemple minimal
# df : DataFrame d'entrée (pandas)
# pd / np disponibles, log(msg) pour tracer
import requests
payload = df.to_dict(orient="records")
resp = requests.post("https://api.example.com/ingest", json=payload, timeout=30)
resp.raise_for_status()
log(f"{len(df)} lignes envoyées, statut {resp.status_code}")
Paramètres
| Paramètre | Type | Requis | Description |
|---|---|---|---|
python_code | String | Oui | Le code Python (éditeur CodeMirror intégré). |
pip_packages | String | Non | Packages pip à installer avant l'exécution (un par ligne ou séparés par des virgules). |
timeout_seconds | Integer | Non | Durée maximale d'exécution (60 s par défaut). |
Le code s'exécute sans sandbox, avec les droits du runner. Le code exécuté est tracé dans les logs debug. L'installation de packages pip nécessite un runner avec accès réseau.
Pour générer un flux avec du code Python, voir Code Python (source) ; pour le transformer, voir Code Python.