Examples
34 maintained example pipelines, grouped by topic.
The cannectors/examples/ directory holds 34 maintained YAML
pipelines that the test suite validates on every commit. They cover
every module and most combinations — copying one of them is the
fastest way to bootstrap a new pipeline.
Every example is rendered live elsewhere in this site via
<PipelineExample /> — open any module page and
scroll to "Examples" to see the YAML inline. This page is the index.
Running them
# Validate all
make validate-examples
# Validate one
cannectors validate ./examples/01-http-polling-basic-to-http-batch.yaml
# Dry-run one
cannectors run --dry-run ./examples/01-http-polling-basic-to-http-batch.yamlThey target https://source.example.com / https://destination.example.com
placeholder hosts. Edit the endpoints or copy the file before pointing
at real systems.
HTTP polling
| File | Covers |
|---|---|
| 01-http-polling-basic-to-http-batch.yaml | Basic polling, no auth, batched HTTP output |
| 02-http-polling-page-pagination.yaml | Page-based pagination |
| 03-http-polling-offset-pagination-state.yaml | Offset pagination + state persistence |
| 04-http-polling-cursor-oauth2.yaml | Cursor pagination + OAuth2 |
Webhook
| File | Covers |
|---|---|
| 05-webhook-hmac-to-http-single.yaml | HMAC verification, per-record HTTP output |
| 06-webhook-queue-rate-limit-to-database.yaml | Async queue + rate limit, database output |
Database I/O
| File | Covers |
|---|---|
| 07-database-input-basic-to-http.yaml | Database input → HTTP output |
| 08-database-input-limit-offset-to-database.yaml | Limit/offset pagination, DB → DB |
| 09-database-input-cursor-incremental.yaml | Cursor + incremental queries |
Transformations
| File | Covers |
|---|---|
| 10-mapping-transforms-all.yaml | Every mapping transform |
| 11-condition-nested-routing.yaml | Nested condition routing |
| 12-script-inline-transform.yaml | Inline JavaScript transform |
| 13-script-file-transform.yaml | External JavaScript file |
| 25-loop-cells-extraction.yaml | Iterate cells[] and extract values by columnId |
Enrichment
| File | Covers |
|---|---|
| 14-http-call-get-merge-cache.yaml | GET enrichment, merge, cache |
| 15-http-call-query-header-append.yaml | Query + header keys, append strategy |
| 16-http-call-post-template-replace.yaml | POST + body template, replace strategy |
| 17-sql-call-merge-cache.yaml | SQL enrichment, merge + cache |
| 18-sql-call-append-query-file.yaml | SQL enrichment, append + external query file |
| 42-soap-call-enrichment.yaml | SOAP enrichment, append + cache |
HTTP output specifics
| File | Covers |
|---|---|
| 19-http-output-single-template.yaml | Single-record mode + URL template |
| 20-http-output-retry-auth-api-key.yaml | Retry block + API key auth |
Database output
| File | Covers |
|---|---|
| 21-database-output-transaction-query-file.yaml | Transactional output + external query file |
SOAP
| File | Covers |
|---|---|
| 40-soap-polling-basic-v11.yaml | SOAP 1.1 polling |
| 40b-soap-polling-basic-v12.yaml | SOAP 1.2 polling |
| 41-soap-polling-cursor.yaml | SOAP cursor pagination |
| 43-soap-output-batch.yaml | SOAP batch output |
| 44-soap-output-mtom-emission.yaml | MTOM attachment emission |
| 44b-soap-input-mtom-reception.yaml | MTOM attachment reception |
| 45-soap-output-wssecurity-passwordtext.yaml | WS-Security PasswordText |
| 45b-soap-output-wssecurity-passworddigest.yaml | WS-Security PasswordDigest |
Pipeline-wide concerns
| File | Covers |
|---|---|
| 22-defaults-inheritance.yaml | Top-level defaults + per-module overrides |
| 23-auth-basic-bearer-query-key.yaml | Bearer + basic + API key in one pipeline |
| 24-empty-filter-pass-through.yaml | Empty filter chain (filters: []) |