Astronomer技能
ego lite browser
赞助ego lite 是AI代理运行网页自动化时最快的浏览器，可与Codex或Claude Code共享您的登录状态，零成本，零配置。
Alpha Vantage MCP Server
赞助获取金融市场数据：实时和历史股票、ETF、期权、外汇、加密货币、大宗商品、基本面、技术指标等
aip-user-stories
airflow/.agents/skills/aip-user-stories
从AIP生成经过验证的配方剧本（含PR实现，后模式），或从无实现的AIP生成推测性用户故事（前模式）。使用…
airflow
agents/skills/airflow
查询、管理和排查Apache Airflow的DAG、运行记录、任务及系统配置。支持30多种命令，涵盖DAG检查、运行管理、任务日志、配置查询及直接REST API访问。通过持久化配置管理多个Airflow实例；自动发现本地和Astro部署。同步（等待完成）或异步触发DAG运行，诊断故障，清除运行记录以重试，并通过重试/映射索引过滤访问任务日志。输出...
airflow-adapter
agents/astro-airflow-mcp/.claude/skills/airflow-adapter
用于v2/v3 API兼容性的Airflow适配器模式。在处理适配器、版本检测或添加需要跨版本工作的新API方法时使用。
airflow-hitl
agents/skills/airflow-hitl
在Airflow DAG中使用可延迟操作符实现人工审批关卡、表单输入和分支。四种操作符类型：用于批准/拒绝决策的ApprovalOperator、带表单的多选项选择HITLOperator、人工驱动的任务路由HITLBranchOperator，以及表单数据收集HITLEntryOperator。所有操作符均为可延迟设计，在通过Airflow UI的"必需操作"标签页或REST API等待人工响应时释放工作槽位。支持包括自定义在内的可选功能...
airflow-java-sdk
airflow/.agents/skills/airflow-java-sdk
Guide for contributing to the Airflow Java SDK (AIP-108). Use this skill whenever a contributor is working in the `java-sdk/` directory or on the Java…
airflow-new-sdk
airflow/.agents/skills/airflow-new-sdk
实现Airflow全新语言SDK（AIP-108）的指南。当贡献者希望添加对新编程语言的支持时，可使用此技能——…
airflow-plugins
agents/skills/airflow-plugins
构建嵌入FastAPI应用、自定义UI页面、React组件、中间件、宏和操作符链接的Airflow 3.1+插件，直接集成到Airflow UI中。使用…
airflow-state-store
agents/skills/airflow-state-store
Persists task and asset state across retries and DAG runs using Airflow 3.3's AIP-103 key/value stores (`task_state_store`, `asset_state_store`) and the…
airflow-translations
airflow/.agents/skills/airflow-translations
为Apache Airflow UI添加或更新翻译。指导设置区域设置、搭建翻译文件框架、使用特定区域设置进行翻译…
analyzing-data
agents/skills/analyzing-data
查询数据仓库，利用缓存的模式和概念映射来回答业务问题。支持对重复问题类型进行模式查找和缓存，并通过记录结果来改进后续查询。包含概念到表的映射缓存，以及通过INFORMATION_SCHEMA或代码库grep进行表结构发现。提供run_sql()和run_sql_pandas()内核函数，返回Polars或Pandas DataFrame用于分析。提供CLI命令用于管理概念、模式和表缓存，以及...
annotating-task-lineage
agents/skills/annotating-task-lineage
使用入口和出口为Airflow任务标注数据血缘。支持使用OpenLineage Dataset对象、Airflow Assets和Airflow Datasets定义跨数据库、数据仓库及云存储的输入输出。当运算符缺少内置OpenLineage提取器时作为备用方案；遵循四级优先级系统，其中自定义提取器和OpenLineage方法优先。包含针对Snowflake、BigQuery、S3和PostgreSQL的数据集命名辅助工具，以确保一致性...
authoring-dags
agents/skills/authoring-dags
创建Apache Airflow DAG的引导式工作流，集成验证与测试。采用六阶段结构化方法：发现环境与现有模式、规划DAG结构、遵循最佳实践实现、通过af CLI命令验证、经用户同意测试、迭代修复。用于发现（af config connections、af config providers、af dags list）和验证（af dags errors、af dags get、af dags explore）的CLI命令可提供DAG的即时反馈...
authoring-go-sdk-tasks
agents/skills/authoring-go-sdk-tasks
Writes Airflow task logic in Go using the Airflow Go SDK. Use when the user wants to implement Airflow tasks in Go, asks about `BundleProvider`/`RegisterDags`,…
authoring-java-sdk-tasks
agents/skills/authoring-java-sdk-tasks
使用 Airflow Java SDK 编写 Java、Kotlin 或任何 JVM 语言的 Airflow 任务逻辑。当用户想要在 Java/JVM 中实现 Airflow 任务时使用，询问……
authoring-language-sdk-tasks
agents/skills/authoring-language-sdk-tasks
Airflow语言SDK的语言中立基础——在DAG保留于Python的同时，以非Python语言实现任务逻辑。当用户…
blueprint
agents/skills/blueprint
使用Pydantic验证定义可复用的Airflow任务组模板，并从YAML组合DAG。适用于创建blueprint模板、从YAML组合DAG等场景。
chart-tests
astronomer/.agents/skills/chart-tests
用于编写、编辑、审查或运行Astronomer APC仓库的Helm chart测试。涵盖pytest模式、render_chart()用法、子chart……
checking-freshness
agents/skills/checking-freshness
通过检查表时间戳和更新模式与陈旧度标尺对比，验证数据新鲜度。使用常见ETL命名模式（如_loaded_at、_updated_at、created_at等）识别时间戳列，并查询其最大值以确定数据时效。将数据分为四种新鲜度状态：新鲜（<4小时）、陈旧（4–24小时）、非常陈旧（>24小时）或未知（未找到时间戳）。提供SQL模板，用于检查最近几天的最后更新时间及行数变化趋势。
circleci
astronomer/.agents/skills/circleci
用于编写、编辑或审查Astronomer APC仓库的CircleCI配置。涵盖脚本组织、内联脚本与外部脚本，以及…
configuring-airflow-language-sdks
agents/skills/configuring-airflow-language-sdks
配置Airflow以运行语言SDK任务（Go和未来的原生SDK）——注册协调器，将队列映射到它，确保工作节点上的运行时/工件，…
cosmos-dbt-core
agents/skills/cosmos-dbt-core
使用Astronomer Cosmos将dbt Core项目转换为Airflow DAG或TaskGroup。支持三种组装模式：独立的DbtDag、现有DAG中的DbtTaskGroup，以及用于精细控制的独立Cosmos运算符。根据隔离和性能需求，从八种执行模式（WATCHER、LOCAL、VIRTUALENV、KUBERNETES、AIRFLOW_ASYNC等）中选择。提供三种解析策略（dbt_manifest、dbt_ls、dbt_ls_file、自动），以平衡速度和选择器复杂度...
cosmos-dbt-fusion
agents/skills/cosmos-dbt-fusion
在Snowflake、Databricks、BigQuery或Redshift上为dbt Fusion项目配置Astronomer Cosmos，并支持本地执行。需要Cosmos 1.11.0及以上版本、在Airflow运行时中单独安装dbt Fusion二进制文件，以及使用子进程调用的ExecutionMode.LOCAL模式。支持三种解析策略：dbt_manifest（适用于大型项目，速度最快）、dbt_ls（适用于复杂选择器）或automatic（适用于简单设置）。涵盖用于仓库连接的ProfileConfig配置、用于dbt项目路径的ProjectConfig配置，以及...
creating-openlineage-extractors
agents/skills/creating-openlineage-extractors
针对不受支持的Airflow运算符及复杂血缘场景的自定义OpenLineage提取器。提供两种方案：建议在自有运算符中直接添加OpenLineage方法，或为无法修改的第三方运算符创建自定义提取器。提取器在三个执行节点进行拦截：执行前获取静态血缘、成功后获取运行时输出、可选在失败后获取部分血缘。通过airflow.cfg或环境变量注册提取器...
dag-factory
agents/skills/dag-factory
使用dag-factory YAML配置以声明方式创作Apache Airflow DAG。适用于创建dag-factory模板、从YAML组合DAG以用于dag-factory等场景。
debugging-dags
agents/skills/debugging-dags
针对失败的Airflow DAG进行系统性根因分析与修复，提供结构化调查工作流。引导完成四步诊断流程：识别故障、提取错误详情、收集上下文信息、提供可操作的修复步骤。将故障分为四类（数据、代码、基础设施、依赖），以聚焦调查并建议适当的修复方案。提供即用型CLI命令，用于日志检索、运行对比、任务清除及DAG...
delegating-to-otto
agents/skills/delegating-to-otto
Drives Astronomer's Otto agent (`astro otto`) as a delegated sub-agent for Airflow, dbt, and data-engineering work. Use when the user explicitly asks to "use…
deploying-airflow
agents/skills/deploying-airflow
部署Airflow DAG和项目。当用户想要部署代码、推送DAG、设置CI/CD、部署到生产环境，或询问部署策略时使用…
deploying-go-sdk-bundles
agents/skills/deploying-go-sdk-bundles
编译、打包并部署已编译的Airflow Go SDK包，以便ExecutableCoordinator能够运行它们。当用户想要编译Go任务包时使用，询问…
deploying-java-sdk-bundles
agents/skills/deploying-java-sdk-bundles
构建并部署编译后的Airflow Java SDK包，以便工作节点能够运行它们。当用户想要将JVM任务包打包为JAR，或询问有关…时使用。
discovering-data
agents/skills/discovering-data
发现并探索某个概念或领域的数据。当用户询问某个主题（例如“ARR”、“客户”、“订单”）存在哪些数据，或想要查找……时使用。
已显示 30 / 50 个