Example 1: Customer Enrichment

Enrich pipeline data with customer information from an external API.

Input:

{ "customerId": "CUST-12345" }

Response:

{
  "customerId": "CUST-12345",
  "customerName": "Acme Corporation",
  "customerTier": "premium"
}

Configuration:

{
  "httpRequestConfig": {
    "httpMethod": "GET",
    "urlPath": "/customers/${event.customerId}",
    "timeoutInMillis": 5000
  },
  "httpOutputConfig": {
    "responseToOutputMapper": [
      { "field": "customerName", "jsonPath": "$.name" },
      { "field": "customerTier", "jsonPath": "$.tier" }
    ]
  }
}

Example 2: Webhook Sink

Send enriched events to an external webhook.

Configuration:

"httpRequestConfig": {
  "httpMethod": "POST",
  "urlPath": "/webhooks/usage-events",
  "body": "{\"type\": \"usage\", \"data\": ${event}}",
  "retries": 1
},
"httpOutputConfig": { "continueOnFailure": true }