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 | 通用 | 下载 |
接收器选项
名称 | 类型 | 是否必须 | 默认值 | 描述 |
---|---|---|---|---|
url | String | 是 | - | Http 请求链接 |
headers | Map | 否 | - | Http 标头 |
retry | Int | 否 | - | 如果请求http返回IOException 的最大重试次数 |
retry_backoff_multiplier_ms | Int | 否 | 100 | http请求失败,重试回退次数(毫秒)乘数 |
retry_backoff_max_ms | Int | 否 | 10000 | http请求失败,最大重试回退时间(毫秒) |
connect_timeout_ms | Int | 否 | 12000 | 连接超时设置,默认12s |
socket_timeout_ms | Int | 否 | 60000 | 套接字超时设置,默认为60s |
common-options | 否 | - | Sink插件常用参数,请参考 Sink常用选项 了解详情 |
示例
简单示例:
Http {
url = "http://localhost/test/webhook"
headers {
token = "9e32e859ef044462a257e1fc76730066"
}
}
变更日志
2.2.0-beta 2022-09-26
- 添加Http接收连接器