⭐️
飞书
飞书 数据接收器
支持的引擎
Spark
Flink
SeaTunnel Zeta
主要特性
描述
用于通过数据调用飞书的web hooks。
例如，如果来自上游的数据是 [
年龄: 12, 姓名: tyrantlucifer]，则 body 内容如下：{"年龄": 12, "姓名": "tyrantlucifer"}
提示：飞书接收器仅支持 post json类型的web hook，并且源数据将被视为web hook的正文内容。
数据类型映射
| SeaTunnel 数据类型 | 飞书数据类型 |
|---|---|
| ROW MAP | Json |
| NULL | null |
| BOOLEAN | boolean |
| TINYINT | byte |
| SMALLINT | short |
| INT | int |
| BIGINT | long |
| FLOAT | float |
| DOUBLE | double |
| DECIMAL | BigDecimal |
| BYTES | byte[] |
| STRING | String |
| TIME TIMESTAMP TIME | String |
| ARRAY | JsonArray |
接收器选项
| 名称 | 类型 | 是否必需 | 默认值 | 描述 |
|---|---|---|---|---|
| url | String | 是 | - | 飞书web hook URL |
| headers | Map | 否 | - | HTTP 请求头 |
| common-options | 否 | - | 接收器插件常见参数，请参阅 接收器通用选项 以获取详细信息 |
任务示例
简单示例:
Feishu {
url = "https://www.feishu.cn/flow/api/trigger-webhook/108bb8f208d9b2378c8c7aedad715c19"
}
变更日志
Change Log
| Change | Commit | Version |
|---|---|---|
| [improve] http connector options (#8969) | https://github.com/apache/seatunnel/commit/63ff9f910 | 2.3.10 |
| [Feature][Restapi] Allow metrics information to be associated to logical plan nodes (#7786) | https://github.com/apache/seatunnel/commit/6b7c53d03 | 2.3.9 |
| [Feature][Connector-V2] Support TableSourceFactory/TableSinkFactory on http (#5816) | https://github.com/apache/seatunnel/commit/6f49ec6ea | 2.3.4 |
| [Improve][build] Give the maven module a human readable name (#4114) | https://github.com/apache/seatunnel/commit/d7cd60105 | 2.3.1 |
| [Improve][Project] Code format with spotless plugin. (#4101) | https://github.com/apache/seatunnel/commit/a2ab16656 | 2.3.1 |
| [Feature][Connector-V2][Http] Add option rules && Improve Myhours sink connector (#3351) | https://github.com/apache/seatunnel/commit/cc8bb60c8 | 2.3.0 |
| [Feature][Connector-V2] Add feishu sink (#2381) | https://github.com/apache/seatunnel/commit/0fec8ca43 | 2.2.0-beta |