跳到主要内容
版本:2.3.10

飞书

飞书 数据接收器

支持的引擎

Spark
Flink
SeaTunnel Zeta

主要特性

描述

用于通过数据调用飞书的web hooks。

例如,如果来自上游的数据是 [年龄: 12, 姓名: tyrantlucifer],则 body 内容如下:{"年龄": 12, "姓名": "tyrantlucifer"}

提示:飞书接收器仅支持 post json类型的web hook,并且源数据将被视为web hook的正文内容。

数据类型映射

SeaTunnel 数据类型飞书数据类型
ROW
MAP
Json
NULLnull
BOOLEANboolean
TINYINTbyte
SMALLINTshort
INTint
BIGINTlong
FLOATfloat
DOUBLEdouble
DECIMALBigDecimal
BYTESbyte[]
STRINGString
TIME
TIMESTAMP
TIME
String
ARRAYJsonArray

接收器选项

名称类型是否必需默认值描述
urlString-飞书web hook URL
headersMap-HTTP 请求头
common-options-接收器插件常见参数,请参阅 接收器通用选项 以获取详细信息

任务示例

简单示例:

Feishu {
url = "https://www.feishu.cn/flow/api/trigger-webhook/108bb8f208d9b2378c8c7aedad715c19"
}

变更日志

Change Log
ChangeCommitVersion
[improve] http connector options (#8969)https://github.com/apache/seatunnel/commit/63ff9f9102.3.10
[Feature][Restapi] Allow metrics information to be associated to logical plan nodes (#7786)https://github.com/apache/seatunnel/commit/6b7c53d032.3.9
[Feature][Connector-V2] Support TableSourceFactory/TableSinkFactory on http (#5816)https://github.com/apache/seatunnel/commit/6f49ec6ea2.3.4
[Improve][build] Give the maven module a human readable name (#4114)https://github.com/apache/seatunnel/commit/d7cd601052.3.1
[Improve][Project] Code format with spotless plugin. (#4101)https://github.com/apache/seatunnel/commit/a2ab166562.3.1
[Feature][Connector-V2][Http] Add option rules && Improve Myhours sink connector (#3351)https://github.com/apache/seatunnel/commit/cc8bb60c82.3.0
[Feature][Connector-V2] Add feishu sink (#2381)https://github.com/apache/seatunnel/commit/0fec8ca432.2.0-beta