跳到主要内容
版本：Next

Typesense

描述​

输出数据到 Typesense

主要特性​

选项​

名称类型是否必须默认值
hostsarray是-
collectionstring是-
schema_save_modestring是CREATE_SCHEMA_WHEN_NOT_EXIST
data_save_modestring是APPEND_DATA
primary_keysarray否
key_delimiterstring否_
api_keystring否
max_retry_countint否3
max_batch_sizeint否10
common-options否-

hosts [array]​

Typesense的访问地址，格式为 host:port，例如：["typesense-01:8108"]

collection [string]​

要写入的集合名，例如：“seatunnel”

primary_keys [array]​

主键字段用于生成文档 id。

key_delimiter [string]​

设定复合键的分隔符（默认为 _）。

api_key [config]​

typesense 安全认证的 api_key。

max_retry_count [int]​

批次批量请求最大尝试大小

max_batch_size [int]​

批次批量文档最大大小

common options​

Sink插件常用参数，请参考 Sink常用选项 了解详情

schema_save_mode​

在启动同步任务之前，针对目标侧已有的表结构选择不同的处理方案
选项介绍：
RECREATE_SCHEMA ：当表不存在时会创建，当表已存在时会删除并重建
CREATE_SCHEMA_WHEN_NOT_EXIST ：当表不存在时会创建，当表已存在时则跳过创建
ERROR_WHEN_SCHEMA_NOT_EXIST ：当表不存在时将抛出错误

data_save_mode​

在启动同步任务之前，针对目标侧已存在的数据选择不同的处理方案
选项介绍：
DROP_DATA： 保留数据库结构，删除数据
APPEND_DATA：保留数据库结构，保留数据
ERROR_WHEN_DATA_EXISTS：当有数据时抛出错误

示例​

简单示例

sink {
    Typesense {
        plugin_input = "typesense_test_table"
        hosts = ["localhost:8108"]
        collection = "typesense_to_typesense_sink_with_query"
        max_retry_count = 3
        max_batch_size = 10
        api_key = "xyz"
        primary_keys = ["num_employees","id"]
        key_delimiter = "="
        schema_save_mode = "CREATE_SCHEMA_WHEN_NOT_EXIST"
        data_save_mode = "APPEND_DATA"
      }
}

变更日志​

Change Log
ChangeCommitVersion
[Fix] Fix error log name for SourceSplitEnumerator implements class (#8817)https://github.com/apache/seatunnel/commit/55ed90ecafdev
[Improve] restruct connector common options (#8634)https://github.com/apache/seatunnel/commit/f3499a6eebdev
[Feature]Check Chinese comments in the code (#8319)https://github.com/apache/seatunnel/commit/d58fce1caf2.3.9
[Improve][dist]add shade check rule (#8136)https://github.com/apache/seatunnel/commit/51ef8000162.3.9
[Feature][Restapi] Allow metrics information to be associated to logical plan nodes (#7786)https://github.com/apache/seatunnel/commit/6b7c53d03c2.3.9
[Fix][Connector-V2] Fix known directory create and delete ignore issues (#7700)https://github.com/apache/seatunnel/commit/e2fb6795772.3.8
[Feature][Connector-V2] Support typesense connector (#7450)https://github.com/apache/seatunnel/commit/138d2a4eb22.3.8