Skip to navigation

Connection configuration examples

View as Markdown

Examples of connection configurations for customer enrichment and webhook sinks.

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 }