数据工程师
将以下提示词粘贴到你的 AI 对话框中:
请根据 https://skillhub.cn/install/skillhub.md,安装 @org-02qudk26/data-engineer。
技能介绍
要解决什么问题
当你要设计批处理或流式管道、搭建数据仓库或湖仓一体、落地数据质量与血缘治理时,往往需要在架构选型、编排工具、SLA 与数据契约之间做一连串连贯决策。纯「写 SQL 做分析」或只做 ML 训练、又碰不到真实数据源的场景,并不属于数据工程的主战场。
技能如何工作
该技能把 Agent 定位为资深数据工程师,按固定节奏推进:先定义数据源、SLA 与数据契约,再选架构、存储与编排;实现采集、转换与验证;最后监控质量、成本与运营可靠性。能力面覆盖现代数据栈(如 dbt + 云仓、Delta Lake/Iceberg/Hudi、Fivetran/Airbyte 类集成)、批流 ETL/ELT(Spark、Airflow、Prefect、Dagster 等)、实时事件(Kafka、Flink、CDC)、建模与性能调优,以及 IaC、监控与合规(PII、最小权限、写入生产前校验)。
响应方法上强调:分析规模/延迟/一致性 → 设计架构 → 实现带错误处理与监控的管道 → 在管道内嵌质量检查 → 权衡成本与性能 → 尽早规划治理与告警,并记录数据流与运维手册。
适用边界
- 适合:管道设计、湖仓/云数据平台、质量与血缘、多租户与 CDC 等工程化议题。
- 不适合:仅探索性数据分析;只做模型开发且不涉及管道;无法访问数据源或存储系统时。
使用场景
- Kafka 业务事件需稳定入仓,要设计高吞吐实时管道并定义窗口聚合与乱序处理策略
- 分析团队要统一语义层,需用 Fivetran、dbt 与 Snowflake 搭建星型维度模型与增量加载流程
- AWS 成本与查询性能要兼顾,需基于 Delta Lake 设计分层湖仓并规划 Glue、Athena 或 Redshift Spectrum 访问路径
- 跨库报表口径不一致,需实现 CDC 同步管道并在写入生产表前嵌入数据质量校验与告警
适合人员
- 负责公司级数据平台、要把批流编排、存储选型与 SLA 写进同一套架构方案的平台数据工程师
- 维护 dbt 模型与仓库语义、要把 SCD、分区策略和测试覆盖落实进发布流程的分析工程师
- 用 Airflow 或 Dagster 管理生产 DAG、需要故障恢复、血缘说明和监控告警一并交付的管道运维负责人
- 在 GDPR/行级安全约束下设计多租户数据产品、要规划访问控制与元数据目录的数据架构或治理工程师