Sls
Sls sink connector
Support Those Engines
Spark
Flink
Seatunnel Zeta
主要特性
描述
Sink connector for Aliyun Sls.
从写入数据到阿里云Sls日志服务
为了使用Sls连接器,需要以下依赖关系。 它们可以通过install-plugin.sh或Maven中央存储库下载。
Datasource | Supported Versions | Maven |
---|---|---|
Sls | Universal | Download |
支持的数据源信息
Name | Type | Required | Default | Description |
---|---|---|---|---|
project | String | Yes | - | 阿里云 Sls 项目 |
logstore | String | Yes | - | 阿里云 Sls 日志库 |
endpoint | String | Yes | - | 阿里云访问服务点 |
access_key_id | String | Yes | - | 阿里云访问用户ID |
access_key_secret | String | Yes | - | 阿里云访问用户密码 |
source | String | No | SeaTunnel-Source | 在sls中数据来源标记 |
topic | String | No | SeaTunnel-Topic | 在sls中数据主题标记 |
任务示例
简单示例
此示例写入sls的logstore1的数据。如果您尚未安装和部署SeaTunnel,则需要按照安装SeaTunnel中的说明安装和部署SeaTunnel。然后按照[快速启动SeaTunnel引擎](../../Start-v2/locale/Quick-Start SeaTunnel Engine.md)中的说明运行此作业。
创建RAM用户及授权, 请确认RAM用户有足够的权限来读取及管理数据,参考:RAM自定义授权示例
# Defining the runtime environment
env {
parallelism = 2
job.mode = "STREAMING"
checkpoint.interval = 30000
}
source {
FakeSource {
row.num = 10
map.size = 10
array.size = 10
bytes.length = 10
string.length = 10
schema = {
fields = {
id = "int"
name = "string"
description = "string"
weight = "string"
}
}
}
}
sink {
Sls {
endpoint = "cn-hangzhou-intranet.log.aliyuncs.com"
project = "project1"
logstore = "logstore1"
access_key_id = "xxxxxxxxxxxxxxxxxxxxxxxx"
access_key_secret = "xxxxxxxxxxxxxxxxxxxxxxxxxxxxxx"
}
}
变更日志
Change Log
Change | Commit | Version |
---|---|---|
[Improve] restruct connector common options (#8634) | https://github.com/apache/seatunnel/commit/f3499a6ee | 2.3.10 |
[Feature]Check Chinese comments in the code (#8319) | https://github.com/apache/seatunnel/commit/d58fce1ca | 2.3.9 |
[Improve][dist]add shade check rule (#8136) | https://github.com/apache/seatunnel/commit/51ef80001 | 2.3.9 |
[Improve][Sls] Add sls sink connector、e2e、doc (#7830) | https://github.com/apache/seatunnel/commit/048c47d96 | 2.3.9 |
[Fix][Connector-V2] Fix some throwable error not be caught (#7657) | https://github.com/apache/seatunnel/commit/e19d73282 | 2.3.8 |
[Feature][Connector-V2] add Aliyun SLS connector #3733 (#7348) | https://github.com/apache/seatunnel/commit/527c7c7b5 | 2.3.7 |