benthos:用Go编写的用于日常任务的声明式ETL 源码

Benthos是一种高性能且具有弹性的流处理器,能够以各种代理模式连接各种和并对有效负载执行。 它带有,易于部署和监视,并可以作为静态二进制文件,docker映像或放入您的管道中,从而使它像原生一样自然云化。 Benthos是完全声明性的,在单个配置文件中定义了流管道,可让您指定连接器和处理阶段列表: input : gcp_pubsub : project : foo subscription : bar pipeline : processors : - bloblang : | root.message = this