跳到主要内容
版本:Next

Http

Http 数据接收器

支持引擎

Spark
Flink
SeaTunnel Zeta

主要特性

描述

接收Source端传入的数据,利用数据触发 web hooks。

例如,来自上游的数据为[age: 12, name: tyrantlucifer],则body内容如下:{"age": 12, "name": "tyrantlucifer"}

Tips: Http 接收器仅支持 post json 类型的 web hook,source 数据将被视为 webhook 中的 body 内容。

支持的数据源信息

想使用 Http 连接器,需要安装以下必要的依赖。可以通过运行 install-plugin.sh 脚本或者从 Maven 中央仓库下载这些依赖

数据源支持版本依赖
Http通用下载

接收器选项

名称类型是否必须默认值描述
urlString-Http 请求链接
headersMap-Http 标头
retryInt-如果请求http返回IOException的最大重试次数
retry_backoff_multiplier_msInt100http请求失败,重试回退次数(毫秒)乘数
retry_backoff_max_msInt10000http请求失败,最大重试回退时间(毫秒)
connect_timeout_msInt12000连接超时设置,默认12s
socket_timeout_msInt60000套接字超时设置,默认为60s
common-options-Sink插件常用参数,请参考 Sink常用选项 了解详情

示例

简单示例:

Http {
url = "http://localhost/test/webhook"
headers {
token = "9e32e859ef044462a257e1fc76730066"
}
}

变更日志

2.2.0-beta 2022-09-26

  • 添加Http接收连接器