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
Airflow 適配器模式,用於 v2/v3 API 相容性。在處理適配器、版本偵測或新增需跨版本運作的 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
構建 Airflow 3.1+ 插件,將 FastAPI 應用、自訂 UI 頁面、React 元件、中介軟體、巨集和運算子連結直接嵌入 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
使用 inlets 和 outlets 為 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指令驗證、經使用者同意後測試,以及根據修正反覆迭代。用於探索的CLI指令(af config connections、af config providers、af dags list)與驗證指令(af dags errors、af dags get、af dags explore)可提供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 上,透過本機執行配置 Astronomer Cosmos 以用於 dbt Fusion 專案。需要 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
驅動 Astronomer 的 Otto 代理
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 套件,以便 worker 可以執行它們。當使用者想要將 JVM 任務套件打包成 JAR,或詢問關於…時使用。
discovering-data
agents/skills/discovering-data
探索某個概念或領域的資料。當使用者詢問某個主題(例如「ARR」、「客戶」、「訂單」)有哪些資料存在,或想要尋找…時使用。
已顯示 30 / 50 個