跳到主要内容
版本：Next

Persistiq

Persistiq 源连接器

描述​

用于从 Persistiq 读取数据。

关键特性​

选项​

参数名类型必须默认值描述
urlString是-HTTP 请求 URL
passwordString是-API 密钥用于登录
methodString否getHTTP 请求方法，仅支持 GET、POST 方法
schemaConfig否-HTTP 和 SeaTunnel 数据结构映射
schema.fieldsConfig否-上游数据的模式字段
formatString否json上游数据的格式，现在仅支持 json text，默认 json。
paramsMap否-HTTP 参数
bodyString否-HTTP 请求体
json_fieldConfig否-JSON 字段配置
content_jsonString否-内容 JSON 配置
poll_interval_millisint否-流模式下请求 HTTP API 的间隔（毫秒）
retryint否-如果 HTTP 请求返回 IOException 的最大重试次数
retry_backoff_multiplier_msint否100HTTP 请求失败时的重试退避倍数（毫秒）
retry_backoff_max_msint否10000HTTP 请求失败时的最大重试退避时间（毫秒）
enable_multi_linesboolean否false是否启用多行模式
common-optionsconfig否-源插件通用参数

url [String]​

HTTP 请求 URL

password [String]​

API 密钥用于登录，您可以在 Persistiq 网站获取

method [String]​

HTTP 请求方法，仅支持 GET、POST 方法

params [Map]​

HTTP 参数

body [String]​

HTTP 请求体

poll_interval_millis [int]​

流模式下请求 HTTP API 的间隔（毫秒）

retry [int]​

如果 HTTP 请求返回 IOException 的最大重试次数

retry_backoff_multiplier_ms [int]​

HTTP 请求失败时的重试退避倍数（毫秒）

retry_backoff_max_ms [int]​

HTTP 请求失败时的最大重试退避时间（毫秒）

format [String]​

上游数据的格式，现在仅支持 json text，默认 json。

schema [Config]​

fields [Config]​

上游数据的模式字段

content_json [String]​

此参数可以获取一些 JSON 数据。

json_field [Config]​

此参数帮助您配置模式，因此此参数必须与 schema 一起使用。

通用选项​

源插件通用参数，请参考 源通用选项 详见。

示例​

source {
  Persistiq{
    url = "https://api.persistiq.com/v1/users"
    password = "Your password"
    content_field = "$.users.*"
    schema = {
        fields {
          id = string
          name = string
          email = string
          activated = boolean
          default_mailbox_id = string
          salesforce_id = string
        }
    }
  }
}

变更日志​

Change Log
ChangeCommitVersion
[improve] http connector options (#8969)https://github.com/apache/seatunnel/commit/63ff9f910a2.3.10
[Feature][Connector-V2] Support TableSourceFactory/TableSinkFactory on http (#5816)https://github.com/apache/seatunnel/commit/6f49ec6ead2.3.4
[Improve][build] Give the maven module a human readable name (#4114)https://github.com/apache/seatunnel/commit/d7cd6010512.3.1
[Improve][Project] Code format with spotless plugin. (#4101)https://github.com/apache/seatunnel/commit/a2ab1665612.3.1
[Feature][Connector-V2][Persistiq]Add Persistiq source connector (#3460)https://github.com/apache/seatunnel/commit/aec3912edf2.3.1