跳到主要内容
版本：Next

OneSignal

OneSignal 源连接器

描述​

用于从 OneSignal 读取数据。

关键特性​

选项​

参数名类型必须默认值描述
urlString是-HTTP 请求 URL
passwordString是-认证密钥用于登录
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]​

认证密钥用于登录，您可以在以下链接获取更多详情：

https://documentation.onesignal.com/docs/accounts-and-keys#user-auth-key

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 {
  OneSignal {
    url = "https://onesignal.com/api/v1/apps"
    password = "SeaTunnel-test"
    schema = {
       fields {
         id = string
         name = string
         gcm_key = string
         chrome_key = string
         created_at = string
         updated_at = string
         players = int
         messageable_players = int
         basic_auth_key = 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
[Improve][Connector-V2][Http]Improve json parse option rule for all http connector (#3627)https://github.com/apache/seatunnel/commit/589e4161ec2.3.0
[Improve][Connector-V2][OneSignal]Unified exception for OneSignal connector (#3609)https://github.com/apache/seatunnel/commit/97cce8c2552.3.0
[Feature][Connector-V2][HTTP] Use json-path parsing (#3510)https://github.com/apache/seatunnel/commit/1807eb6c952.3.0
[Hotfix][OptionRule] Fix option rule about all connectors (#3592)https://github.com/apache/seatunnel/commit/226dc6a1192.3.0
[Feature][Connector-V2][OneSignal]Add OneSignal source conector (#3454)https://github.com/apache/seatunnel/commit/b318b3166f2.3.0