kestra

Kestra 是一个统一了定时调度和事件驱动自动化的编排平台。它允许用户使用声明式 YAML 接口构建可靠的工作流，这些工作流可以通过内置的 UI 代码编辑器进行管理，或与 Git 集成以实现基础设施即代码 (IaC) 实践。 核心能力包括： - 工作流管理：支持命名空间、标签、子流、重试、超时、条件分支和动态任务。 - 执行与扩展：专为高可用性和容错设计，能够处理数百万个工作流。它支持本地执行、通过 SSH 连接远程服务器，以及通过 Task Runners（包括 Docker 和 Kubernetes）运行无服务器容器。 - 插件生态系统：提供数百个内置插件，用于数据库提取、云存储和 API 交互。它支持多种语言的脚本编写，包括 Python、Node.js、R、Go 和 Shell。 - 事件驱动触发器：能够实时响应外部事件，例如文件到达或来自 Kafka、Redis、Pulsar、AMQP、MQTT、NATS、AWS SQS、Google Pub/Sub 和 Azure Event Hubs 的消息。 - 可视化工具：具有用于拖拽任务排列的 Topology Editor，支持实时语法验证、自动补全以及实时 DAG（有向无环图）视图。 - 集成：提供官方 Terraform provider，并支持 CI/CD 流水线集成以进行工作流部署。