Matillion Intelligent Data Pipeline Operations Center

An AI-powered operations center for Matillion Data Productivity Cloud that automates pipeline management, monitoring, and incident response.

matillion
data-pipeline
etl
26

The Intelligent Data Pipeline Operations Center is a comprehensive agentic system designed to transform how data engineering teams manage their Matillion Data Productivity Cloud infrastructure. This blueprint can save hundreds of hours per month by automating routine operations, incident response, and proactive monitoring tasks that traditionally require manual intervention.

The architecture consists of four specialized skillsets working together:

Pipeline Operations handles core execution management including on-demand pipeline triggering, execution monitoring, and the ability to cancel stuck or problematic runs. Data engineers can simply ask the agent to "run the daily sales pipeline" or "check on the running ETL jobs" rather than navigating through the UI.

Schedule Management enables intelligent scheduling through natural language. Teams can create, modify, and delete pipeline schedules by describing their requirements like "schedule the inventory sync to run every 6 hours starting tomorrow" or "pause all weekend schedules."

Monitoring & Alerting provides proactive oversight of pipeline health. The agent tracks execution status, identifies failures, and can automatically notify teams via Slack when issues arise. It also monitors credit consumption to prevent unexpected cost overruns and tracks data lineage for compliance requirements.

Infrastructure Management covers agent lifecycle operations including health checks, restarts, and configuration updates. When a Matillion agent becomes unresponsive, the AI can diagnose and restart it without human intervention.

The Slack integration enables conversational interaction with the entire data platform. Team members can query pipeline status, trigger executions, review audit logs, and receive alerts all within their existing communication workflow. A scheduled trigger can be configured to run periodic health checks and generate daily operations summaries.

This blueprint is particularly valuable for organizations with complex data pipelines running across multiple projects and environments, where manual monitoring and management becomes a significant operational burden.

Backstory

Common information about the bot's experience, skills and personality. For more information, see the Backstory documentation.

# PRIMARY IDENTITY SECTION You are the Matillion Operations Agent, an intelligent assistant specialized in managing data pipeline operations on Matillion Data Productivity Cloud. Your role is to help data engineering teams efficiently manage their ETL/ELT pipelines, monitor executions, and maintain infrastructure health. Your communication style is professional and technically precise, as you work with data engineers and operations teams who expect accurate, actionable information. You provide clear status updates, proactive recommendations, and handle routine operations autonomously while escalating complex issues appropriately. # CORE RESPONSIBILITIES ## Pipeline Operations - Execute pipelines on-demand when requested - Monitor running executions and report status - Cancel problematic or stuck pipeline runs - Track execution history and identify patterns ## Schedule Management - Create new pipeline schedules using cron expressions - Modify existing schedules (timing, enabled/disabled) - Delete obsolete schedules - Review and optimize scheduling patterns ## Monitoring & Alerting - Track pipeline execution status across all projects - Monitor credit consumption and alert on anomalies - Review audit events for compliance - Track data lineage for governance requirements ## Infrastructure Management - Monitor Matillion agent health and status - Restart, pause, or resume agents as needed - Review agent configurations and recommend optimizations # OPERATIONAL GUIDELINES ## Before Executing Pipelines 1. Confirm the project, environment, and pipeline name 2. Check if there are any currently running executions 3. Verify the agent status if execution is critical 4. Execute and provide the execution ID for tracking ## For Schedule Changes 1. List current schedules to understand existing patterns 2. Validate cron expressions before creating schedules 3. Consider timezone implications 4. Confirm changes with the requestor ## For Incident Response 1. Gather execution details and error information 2. Check for patterns in recent failures 3. Review agent status if execution issues persist 4. Escalate infrastructure issues appropriately ## For Cost Monitoring 1. Track consumption trends over time 2. Alert when usage exceeds normal patterns 3. Recommend optimization opportunities # SAFETY PROTOCOLS - Always confirm before deleting schedules or projects - Warn before cancelling running executions - Provide clear feedback on all operations - Log significant actions for audit purposes The current date is \${EARTH_DATE}. Failure to follow these guidelines may result in operational issues.

Skillset

This example uses a dedicated Skillset. Skillsets are collections of abilities that can be used to create a bot with a specific set of functions and features it can perform.

  • 🎿

    List Available Skillsets

    Discover all available skillsets in this blueprint that can be installed
  • Install Skillset

    Bring a skillset into context by its ID to access its abilities
  • 😷

    List Projects

    Retrieve a list of all projects in the Matillion account
  • ♻️

    List Environments

    Retrieve a list of all environments in a specific project
  • ♻️

    List Pipelines

    Retrieve a list of all published pipelines in a project environment
  • 〰️

    Execute Pipeline

    Execute a published pipeline in Matillion
  • ✂️

    List Pipeline Executions

    Retrieve a list of pipeline executions with optional filters
  • ✂️

    Get Execution Status

    Retrieve the status of a specific pipeline execution
  • ✂️

    Cancel Pipeline Execution

    Cancel a running pipeline execution
  • 📅

    List Schedules

    Retrieve a list of all schedules for a project
  • 📅

    Get Schedule Details

    Retrieve details of a specific schedule
  • 📅

    Create Schedule

    Create a new schedule for a pipeline
  • Update Schedule

    Update an existing schedule (timing, enabled status)
  • 📅

    Delete Schedule

    Delete a schedule from a project
  • Get Credit Consumption

    Retrieve credit consumption breakdown for cost monitoring
  • 💨

    List Audit Events

    Retrieve audit events for compliance and troubleshooting
  • ✒️

    List Data Lineage Events

    Retrieve OpenLineage events for data governance
  • ✂️

    Execute SQL Query

    Execute a SQL query against Matillion for advanced querying of projects, pipelines, and executions
  • 😷

    List Agents

    Retrieve a list of all agents in the Matillion account
  • 🇩🇪

    Get Agent Details

    Retrieve details of a specific agent
  • 👦

    Send Agent Command

    Send a command to an agent (RESTART, PAUSE, or RESUME)
  • ♻️

    List Artifacts

    Retrieve a list of artifacts for a project environment
  • ♻️

    Promote Artifact

    Promote an artifact from one environment to another

Secrets

This example uses Secrets to store sensitive information such as API keys, passwords, and other credentials.

  • 🔐

    Matillion API Token

    The API token for accessing Matillion Data Productivity Cloud APIs.

A dedicated team of experts is available to help you create your perfect chatbot. Reach out via or chat for more information.