数据源
Timeplus与各种系统相结合，作为数据来源，例如Apache Kafka。
您可以定义一个或多个源来设置后台任务将数据加载到Timeplus中。 更多详情请检查 数据导入 部分。
如果您需要调用 API 来创建数据源，以下是参考资料。
请参考 https://kafka.apache.org/
| 属性 | 必填项 | 描述 | 默认值 |
|---|
| brokers | yes | 指定broker地址列表。 这是一个以逗号分隔的字符串。 例如kafka1:9092,kafka2:9092,kafka3:9092 | |
| 主题 | yes | 指定要连接的Kafka主题 | |
| offset | yes | 指定Kafka offset配置。 支持latest,earliest | |
| data_type | yes | 指定用于创建流的数据类型。 支持json，text，avro，debezium-json，debezium-json-upsert | |
| group | no | 指定Kafka消费者组。 如果用户未指定，则使用带有timeplus-source前缀的源uuid作为默认值 | timeplus-source-<uuid> |
| sasl | no | 指定用于简单身份验证和安全层（SASL）的认证机制。 支持none，plain，scram-sha-256，scram-sha-512 | none |
| 用户名 | no | 指定用于身份验证的用户名 | |
| 密码 | no | 指定用于身份验证的密码 | |
| tls.disable | no | 如果设置为true，则禁用 TLS 加密 | false |
| tls.skip_verify_server | no | 如果设置为true，则在使用 TLS 时会跳过服务器证书验证 | false |
| schema_registry_address | no | 为Kafka指定架构注册表的URL，仅在data_type为avro时适用 | |
| schema_registry_api_key | no | 为架构注册表身份验证指定API密钥 | |
| schema_registry_api_secret | no | 为架构注册表身份验证指定API密钥 | |
生成用于测试的随机数据的源
| 属性 | 必填项 | 描述 | 默认值 |
|---|
| template | yes | 指定用于生成数据的模板，支持iot，user_logins，devops | |
| 间隔 | no | 指定事件间隔。 例如：200ms | 200ms |
请参阅 https://developer.mozilla.org/en-US/docs/Web/API/WebSocket
| 属性 | 必填项 | 描述 | 默认值 |
|---|
| url | yes | 指定 websocket 服务器网址的 URL | |
| 打开消息 | no | 连接时发送给服务器的可选消息。 | |
| open_message_type | no | 指定用于创建流的数据类型。 support json,text, | text |
| data_type | yes | 指定用于创建流的数据类型。 支持 json,文本, | |
请参阅 https://docs.nats.io/nats-concepts/what-is-nats
| 属性 | 必填项 | 描述 | 默认值 |
|---|
| url | yes | 要连接的 URL 列表。例如 [nats: //127.0.0. 1:4222] | |
| 主题 | yes | 可从中食用。 A subject to consume from. Supports wildcards for consuming multiple subjects. | |
| 排队 | no | 可选队列组，可用作使用。 | |
| nak_delay | no | 在被否定确认后重新传送消息时可选的延迟时间。 | |
| prefetch_count | no | 一次提取的最大消息数。 | 524288 |
| data_type | yes | 指定用于创建流的数据类型。 支持 json,文本, | |
| tls.disable | no | 如果设置为true，则禁用 TLS 加密 | false |
| tls.skip_verify_server | no | 如果设置为true，则在使用 TLS 时会跳过服务器证书验证 | false |
请参阅 https://docs.nats.io/nats-concepts/jetstream
| 属性 | 必填项 | 描述 | 默认值 |
|---|
| url | yes | 要连接的 URL 列表。例如 [nats: //127.0.0. 1:4222] | |
| 主题 | yes | 可从中食用。 A subject to consume from. Supports wildcards for consuming multiple subjects. | |
| 排队 | no | 可选队列组，可用作使用。 | |
| 耐用的 | no | 使用耐用的名称保留消费者的状态。 | |
| 流 Stream | no | 可供消费的流。 A stream to consume from. Either a subject or stream must be specified.. | |
| 配送 | no | Determines which messages to deliver when consuming without a durable subscriber. support all last 支持 全部 最后 | 所有 |
| 捆绑 | no | 布尔值表示订阅应使用现有消费者。 | |
| ack_wait | no | NATS 服务器等待消费者回复的最大时间。 | 30 秒 |
| max_ack_pending | no | 停止消耗之前允许的最大未完成 ack 数量。 | 1024 |
| data_type | yes | 指定用于创建流的数据类型。 支持json，text | |
| tls.disable | no | 如果设置为true，则禁用 TLS 加密 | false |
| tls.skip_verify_server | no | 如果设置为true，则在使用 TLS 时会跳过服务器证书验证 | false |
请参考https://pulsar.apache.org/
| 属性 | 必填项 | 描述 | 默认值 |
|---|
| 主题 | yes | 指定要连接的pulsar的主题 | |
| 经纪网址 | yes | 指定要连接的broker URL | |
| auth_type | yes | 指定要使用的身份验证类型。 支持``，oauth2，token | |
| auth_params | no | 将身份验证参数指定为键值对 | {} |
参考https://livepeer.org/
| 属性 | 必填项 | 描述 | 默认值 |
|---|
| 间隔 | yes | 指定livepeer api的拉取间隔。 例如：300s | |
| api_key | yes | 指定livepeer的API 密钥 | |
| data_type | yes | 指定用于创建流的数据类型。 支持json，text | |
参考https://ably.com/
| 属性 | 必填项 | 描述 | 默认值 |
|---|
| api_key | yes | api_key的属性是一个字符串，用于对Ably服务进行身份验证和授权。 它代表与Ably账户关联的API密钥，是向Ably的服务发出经过身份验证的请求所需要的 | |
| channel | yes | channel的属性制定了向其发送消息或从中接收消息的channel的名称。 Ably中的channels用于对消息进行分组和分类。 这个属性允许你为互动选择目标渠道 | |