ae-dataops

AE Data Development and Operations: Data warehouse management, flow orchestration, IDE queries, and data integration

By thinkingaiagenticengine · 526 installs

npx skills add thinkingaiagenticengine/ae-cli --skill ae-dataops

Source repository · Upstream listing

ae dataops CRITICAL This skill is self contained. Use the Global AE CLI Rules below; do not require a separate shared skill for DataOps side tasks. The AE Data Development and Operations domain provides capabilities for data warehouse management, flow orchestration, IDE SQL queries, data integration, operations and backfill management, including the following subcommands: Subcommand Responsibility Corresponding Scenario Skill dataops repo Space discovery — dataops datatable Data table and view management dataops table dataops flow Flow creation, node deletion, and orchestration dataops flow create dataops flow Flow execution and monitoring dataops flow monitor dataops operations Operations instance search, details, and task logs dataops flow monitor dataops operations Backfill job creation, full draft update, deletion, execution, plans, stop, and rerun dataops backfill dataops ide Data exploration and SQL queries dataops query dataops integration Datasource and data integration dataops integration Global AE CLI Rules AE CLI ( ae cli ) is the command line tool for the AE / TE / ThinkingEngine analysis platform. For AE analysis side requests, prefer ae cli and this skill's reference docs over model memory. Global parameters: Parameter Description format <json\ table Output format. Default is JSON. jq <expr jq filter expression for JSON output. host <url Override the active AE host. Available on every command and may be placed after the subcommand, e.g. ae cli dataops ide +<command host <url . Output and errors: Successful commands return machine readable JSON by default. Envelope may include optional notice.host compat . Failed commands return { "ok": false, "error": { "type": "...", "message": "...", "hint": "..." } } and exit non zero. CRITICAL — Host compat (do this first): After each ae cli run, check stderr and notice.host compat . If either is present, open the user reply with a short ⚠️ version warning and quote the npm i g / npx skills add (or update cluster) lines verbatim , then present the business result. Soft tip; ok: true can still carry the notice. Safety constraints: Read commands can execute directly after required IDs and references are verified. Ordinary write commands execute without yes ; use yes only for a high risk write command after explicit user confirmation. Never invent command names, flags, JSON payloads, project id , resource IDs, field names, event names, property names, metric definitions, or date formats. Read the matching command reference and discover real project metadata first. NEVER fabricate or guess resource names (reports, dashboards, events, properties, metrics, clusters, tags, alerts). Always use list commands to discover real resources first. If a resource is not found after fuzzy search and full list fallback, explicitly tell the user "resource not found" and stop do not proceed with fabricated names. Domains for DataOps: dataops repo , dataops datatable , dataops flow , dataops operations , dataops ide , dataops integration Core Concepts and Rules You must understand the following key concepts before use, otherwise errors are highly likely. ID System ID Source Usage Scope executeId Returned by dataops flow +execute flow Early stop handle before the scheduler flowInstanceId is available flowInstanceId Returned by dataops operations +search flow instances Operations perspective instance inspection and stop jobId Returned by dataops operations +create backfill job or +search backfill jobs Persistent backfill job detail and lifecycle actions Environment and Defaults Scenario Default Environment Description Most flow/ide/datatable commands DEV Development environment dataops operations +search flow instances Operations instance search Filter by keyword, execution date, status, and paging dataops operations +get flow instance detail Instance detail Inspect one instance DAG and task statuses dataops operations +get task instance detail Task detail/logs Inspect one task and include logs only when needed dataops operations +stop flow instance Instance stop Stop by exactly one of executeId or flowInstanceId dataops operations +list backfill flows Backfill source discovery Returns eligible PROD flows and whether ST is required dataops operations +search backfill jobs Backfill job search Filter persistent jobs and obtain jobId Schema Naming Rules DEV environment: ws ${spaceCode} dev PROD environment: ws ${spaceCode} product Responsibility Boundaries Operation Correct Tool Prohibited Execute SELECT queries dataops ide — Create/modify/delete data tables (DDL) dataops datatable dataops ide Flow Lifecycle Backfill lifecycle: Discover eligible PROD flow → Create or fully update DRAFT job → Run explicitly → Search / inspect plans → Stop or rerun the complete job; delete only after target inspection CRON Format (6 fields) second minute hour day month weekday — Note: one more "second" field than standard 5 field format. 0 0 2 ? — Daily at 2 AM 0 0 /4 ? — Every 4 hours 0 30 8 1 5 — Weekdays at 8:30 Preset Repository vs Non Preset Repository Preset Repository (te etl) : datasourceId is te etl@TASK ENGINE TRINO , database field is empty, requires gatewayConfig Non Preset Repository : datasourceId is specific datasource ID, database field is required Scenario Routing Choose the appropriate scenario skill based on user intent to get complete step by step workflow guidance. User Intent Trigger Skill Keywords Create flow, add or delete nodes, configure schedule, release dataops flow create create flow, new workflow, configure schedule, add task node, delete task node, release, cron, scheduled execution View execution status, troubleshoot failures, view logs dataops flow monitor execute flow, running instance, monitor, logs, stop, DAG, troubleshoot Search operation instances across a space dataops flow monitor operations instance, flow instance search, status statistics, owner statistics Create or operate a persistent multi date backfill job dataops backfill backfill, fill historical data, base date range, backfill plans, stop backfill, rerun backfill Create datasource, configure sync solution, execute sync dataops integration datasource, sync, integration, field mapping, data ingestion, MySQL, ClickHouse, DatabricksJdbc Browse metadata, search tables, execute SQL queries dataops query query, SQL, data exploration, search tables, view table structure, IDE, catalog, select Create tables and views dataops table create table, table creation, view, data dictionary, table details, DDL 1. Space Discovery dataops repo exposes only one read command. Use it to discover a valid spaceCode before calling DataOps commands that require one. It returns createTime , spaceCode , and spaceDisplayName . If the user already provided a trusted spaceCode , reuse it. If spaceCode is unknown, run +list spaces first. If exactly one space is returned, use its spaceCode . If multiple spaces are returned and the user intent does not identify one, ask the user which space to use. Do not guess. 2. Data Table and View Management Detailed workflow, command flags, examples, and parameter notes live in [ references/dataops table.md ](references/dataops table.md). Key constraints: Start with dataops datatable +dict search tables for visible DataOps catalog discovery. Use dataops ide +search tables only for raw engine metadata, and dataops ide +ide list tables only for known catalog/schema browsing. Create tables/views with dataops datatable , not dataops ide ; creation is DEV only and must be published with +publish entity . DDL follows Trino syntax; current space view DDL should keep the literal ${env} placeholder. 3. Flow Orchestration Flow orchestration is divided into two scenario skills: creation and configuration and execution and monitoring . Lifecycle: DEV configuration and preview → Release to PROD → PROD manual execution and operations troubleshooting Detailed creation/configuration commands live in [ references/dataops flow create.md ](references/dataops flow create.md). Detailed execution, monitoring, operation instance, task log, and stop commands live in [ references/dataops flow monitor.md ](references/dataops flow monitor.md). Persistent multi date backfill jobs live in [ references/dataops backfill.md ](references/dataops backfill.md). Key constraints: Create and update tasks in DEV, preview/release before PROD execution. Treat +delete task as high risk: verify the target with +get flow overview , preview with dry run , and use yes only after explicit user confirmation. Deletion affects DEV; release the flow to apply it to PROD. +execute flow always runs PROD; it returns executeId for early stop. Prefer flowInstanceId from operations search for stable inspection and troubleshooting. A backfill job is persistent and batches multiple base dates; do not emulate it by looping +execute flow . Create and run backfill jobs as separate steps. +rerun backfill job reruns the complete job, not only failed plans. +update backfill job replaces a DRAFT job's complete configuration; inspect the job first and do not treat it as a partial patch. Treat +delete backfill job as high risk and preview it with dry run before confirmation. Reference workspace parameters in task SQL as ${paramKey} . 4. IDE SQL Queries Detailed metadata browsing, SQL query, async download, and cancel workflows live in [ references/dataops query.md ](references/dataops query.md). Key constraints: IDE is query only; create/modify/delete tables with dataops datatable . Prefer dataops datatable +dict search tables for table discovery unless raw engine metadata or schema browsing is required. Submit exactly one read only SQL query. It creates a platform bounded download task; rows are not returned inline and the result is not an unlimited or full export. 5. Data Integration Detailed datasource, metadata browsing, sync solution, execution, and monitoring workflows live in [ references/dataops integration.md ](references/dataops integration.md). Key constraints: Generate sourceConfig , sinkConfig , channelConfig , and fieldsMapping from the reference templates; do not invent keys. MySQL Source read partitioning uses sourceConfig.splitColumn ; fieldsMapping.shardingKey is column metadata and must not be used for it. +save sync solution is not a partial patch: call +get sync detail withParams true first, then submit complete configs. syncName is accepted for compatibility but ignored. Preset repository sync uses te etl@TASK ENGINE TRINO and requires gateway configuration. Use +list sync runs to get taskId before stopping a running sync. Reference Documentation For detailed command flags and usage, please refer to the command documentation in the [ references/ ](references/) directory.