Complete AI TrainingYourJobSkills for your job

Skills / data

monte-carlo-push-ingestion

Expert guide for pushing metadata, lineage, and query logs to Monte Carlo from any data warehouse.

Finance & AccountingData & Analyticsdata-observabilityingestionmetadatamonte-carlopycarlo

Monte Carlo Push Ingestion

You are an agent that helps customers collect metadata, lineage, and query logs from their data warehouses and push that data to Monte Carlo via the push ingestion API. The push model works with any data source — if the customer's warehouse does not have a ready-made template, derive the appropriate collection queries from that warehouse's system catalog or metadata APIs. The push format and pycarlo SDK calls are the same regardless of source.

Monte Carlo's push model lets customers send metadata, lineage, and query logs directly to Monte Carlo instead of waiting for the pull collector to gather it. It fills gaps the pull model cannot always cover — integrations that don't expose query history, custom lineage between non-warehouse assets, or customers who already have this data and want to send it directly.

When to Use

Use this skill when the user needs to collect metadata, lineage, freshness, volume, or query-log data from a warehouse or adjacent system and push it into Monte Carlo through the push-ingestion API.

Push data travels through the integration gateway → dedicated Kinesis streams → thin adapter/normalizer code → the same downstream systems that power the pull model. The only new infrastructure is the ingress layer; everything after it is shared.

MANDATORY — Always start from templates

When generating any push-ingestion s

Subscribers only

The full skill, its 69 bundled files and every download is included with every paid Complete AI plan.

Details

Sourcemonte-carlo-data/mc-agent-toolkit
License
Risk labelsafe ("critical" means the skill may run commands or touch files — read before use)
FilesSKILL.md, references/anomaly-detection.md, references/custom-lineage.md, references/direct-http-api.md, references/prerequisites.md, references/push-lineage.md, references/push-metadata.md, references/push-query-logs.md, references/validation.md, scripts/sample_verify.py, scripts/templates/bigquery-iceberg/_safe_paths.py, scripts/templates/bigquery-iceberg/collect_and_push_metadata.py, scripts/templates/bigquery-iceberg/collect_and_push_query_logs.py, scripts/templates/bigquery-iceberg/collect_metadata.py, scripts/templates/bigquery-iceberg/collect_query_logs.py, scripts/templates/bigquery-iceberg/push_metadata.py, scripts/templates/bigquery-iceberg/push_query_logs.py, scripts/templates/bigquery/_safe_paths.py, scripts/templates/bigquery/collect_and_push_lineage.py, scripts/templates/bigquery/collect_and_push_metadata.py, scripts/templates/bigquery/collect_and_push_query_logs.py, scripts/templates/bigquery/collect_lineage.py, scripts/templates/bigquery/collect_metadata.py, scripts/templates/bigquery/collect_query_logs.py, scripts/templates/bigquery/push_lineage.py, scripts/templates/bigquery/push_metadata.py, scripts/templates/bigquery/push_query_logs.py, scripts/templates/databricks/_safe_paths.py, scripts/templates/databricks/collect_and_push_lineage.py, scripts/templates/databricks/collect_and_push_metadata.py, scripts/templates/databricks/collect_and_push_query_logs.py, scripts/templates/databricks/collect_lineage.py, scripts/templates/databricks/collect_metadata.py, scripts/templates/databricks/collect_query_logs.py, scripts/templates/databricks/push_lineage.py, scripts/templates/databricks/push_metadata.py, scripts/templates/databricks/push_query_logs.py, scripts/templates/hive/_safe_paths.py, scripts/templates/hive/collect_and_push_lineage.py, scripts/templates/hive/collect_and_push_metadata.py, scripts/templates/hive/collect_and_push_query_logs.py, scripts/templates/hive/collect_lineage.py, scripts/templates/hive/collect_metadata.py, scripts/templates/hive/collect_query_logs.py, scripts/templates/hive/push_lineage.py, scripts/templates/hive/push_metadata.py, scripts/templates/hive/push_query_logs.py, scripts/templates/redshift/_safe_paths.py, scripts/templates/redshift/collect_and_push_lineage.py, scripts/templates/redshift/collect_and_push_metadata.py, scripts/templates/redshift/collect_and_push_query_logs.py, scripts/templates/redshift/collect_lineage.py, scripts/templates/redshift/collect_metadata.py, scripts/templates/redshift/collect_query_logs.py, scripts/templates/redshift/push_lineage.py, scripts/templates/redshift/push_metadata.py, scripts/templates/redshift/push_query_logs.py, scripts/templates/snowflake/_safe_paths.py, scripts/templates/snowflake/collect_and_push_lineage.py, scripts/templates/snowflake/collect_and_push_metadata.py, scripts/templates/snowflake/collect_and_push_query_logs.py, scripts/templates/snowflake/collect_lineage.py, scripts/templates/snowflake/collect_metadata.py, scripts/templates/snowflake/collect_query_logs.py, scripts/templates/snowflake/push_lineage.py, scripts/templates/snowflake/push_metadata.py, scripts/templates/snowflake/push_query_logs.py, scripts/test_template_sdk_usage.py, scripts/test_template_security_guards.py
Added2026-04-08

Related skills

alpha-vantage

Access 20+ years of global financial data: equities, options, forex, crypto, commodities, economic indicators, and 50+ technical indicators.

amplitude-automation

Automate Amplitude tasks via Rube MCP (Composio): events, user activity, cohorts, user identification. Always search tools first for current schemas.

analytics-product

Analytics de produto — PostHog, Mixpanel, eventos, funnels, cohorts, retencao, north star metric, OKRs e dashboards de produto.

analytics-tracking

Design, audit, and improve analytics tracking systems that produce reliable, decision-ready data.

arrowspace

Spectral vector search using graph Laplacian eigenstructure. Use when cosine/L2 similarity misses latent structure in your embeddings.

data-engineer

Build scalable data pipelines, modern data warehouses, and real-time streaming architectures. Implements Apache Spark, dbt, Airflow, and cloud-native data platforms.