Generate complete Klaviyo ingestion workflow with all data sources using exact templates
Generates complete Klaviyo ingestion workflow with all data sources using exact templates
/plugin marketplace add treasure-data/aps_claude_tools/plugin install treasure-data-cdp-ingestion-plugins-cdp-ingestion@treasure-data/aps_claude_toolsI'll create a complete Klaviyo ingestion setup based on proven templates from docs/sources/klaviyo.md.
I will generate ALL of the following files in a SINGLE response using multiple Write tool calls:
ingestion/klaviyo_ingest_inc.dig - Incremental ingestion workflowingestion/klaviyo_ingest_hist.dig - Historical backfill workflowingestion/config/)klaviyo_datasources.yml - Datasource definitions for all objectsklaviyo_profiles_load.yml - Profiles configurationklaviyo_events_load.yml - Events configurationklaviyo_campaigns_load.yml - Campaigns configurationklaviyo_lists_load.yml - Lists configurationklaviyo_email_templates_load.yml - Email templates configurationklaviyo_metrics_load.yml - Metrics configurationcredentials_ingestion.json with Klaviyo credentials sectionTotal: 10 files created in ONE response
Please provide the following information:
klaviyo_auth_default)YYYY-MM-DDTHH:MM:SS.0000002023-09-01T00:00:00.000000client_src (leave blank to use default)I will READ these documentation files BEFORE generating ANY code:
docs/sources/klaviyo.md - Klaviyo exact templatesdocs/patterns/workflow-patterns.md - Workflow patternsdocs/patterns/logging-patterns.md - Logging templatesdocs/patterns/timestamp-formats.md - Klaviyo timestamp format (.000000)docs/patterns/incremental-patterns.md - Dual field names for campaignsUsing multiple Write tool calls in a SINGLE message:
Templates will be copied character-for-character from documentation:
.000000 (6 decimals, NO Z)updated_at in table, updated in APIBefore delivering, I will verify:
✅ All 10 files created
✅ Klaviyo timestamp format: .000000 (6 decimals, NO Z)
✅ Campaigns dual field names correct
✅ Events config has NO incremental_field parameter
✅ All logging blocks present (start, success, error)
✅ All error handling blocks present
✅ Parallel processing with limit: 3
✅ COALESCE fallback to historical table
updated)updated_at in table, updated in API)updated)updated)updated).000000 (6 decimals, NO Z suffix)# Navigate to your ingestion directory
cd ingestion/
td wf secrets --project ingestion --set @credentials_ingestion.json
td wf check klaviyo_ingest_inc.dig
td wf check klaviyo_ingest_hist.dig
td wf run klaviyo_ingest_hist.dig
td wf run klaviyo_ingest_inc.dig
SELECT * FROM client_src.ingestion_log
WHERE source_name LIKE 'klaviyo%'
ORDER BY time DESC
LIMIT 20
All generated code will:
docs/sources/klaviyo.md.000000)Ready to proceed? Provide the required information (API key, TD auth ID, start date) and I'll generate all 10 files in ONE response using exact templates from documentation.