跳到主要内容
版本：Next

Sentry

Sentry 数据接收器

支持的引擎​

Spark
Flink
SeaTunnel Zeta

关键特性​

描述​

将 SeaTunnel 行数据作为消息写入 Sentry。每一行都会通过 Sentry SDK 调用 Sentry.captureMessage(row.toString()) 进行发送。该连接器适合将 SeaTunnel 中的事件统一转发到 Sentry，与其他业务事件一起做告警和聚合分析。

数据类型映射​

所有行字段值在传入 Sentry SDK 之前都会通过 row.toString() 转成字符串，因此无论源字段类型 是什么，最终发送给 Sentry 的消息载荷始终是字符串。

SeaTunnel 数据类型Sentry 消息格式
stringString
tinyint / smallint / int / bigintString (toString)
float / doubleString (toString)
booleanString (toString)
date / time / timestampString (toString)
bytes / array / map / rowString (toString)

选项​

名称类型必需默认值描述
dsnstring是-Sentry SDK 使用的 DSN。
envstring否-Sentry 环境名称，会附加到每一条事件上。
releasestring否-Sentry release 值，会附加到每一条事件上。
cacheDirPathstring否-Sentry SDK 用于缓存离线事件的目录。
enableExternalConfigurationboolean否-是否允许 Sentry SDK 从外部（例如 sentry.properties）加载配置。
maxCacheItemsint否-最大缓存事件数量。SDK 默认值为 30。
flushTimeoutMillislong否-刷新待发送事件时的等待时间，单位毫秒。
maxQueueSizeint否-事件刷新到磁盘前的最大队列大小。
common-options否-接收器插件通用参数，详见 Sink 常见选项。

dsn [string]​

DSN 告诉 SDK 将事件发送到哪里。格式为标准 Sentry DSN，例如 https://<publicKey>@<host>/<projectId>。

env [string]​

指定 Sentry 环境名称（例如 prod、staging），会附加到该接收器捕获的每一条事件上。

release [string]​

指定 Sentry release 值（例如 my-app@1.2.3），会附加到该接收器捕获的每一条事件上。

cacheDirPath [string]​

用于缓存离线事件的目录。当接收器所在环境无法保证 Sentry 服务始终可达时，请配置为本地可写目录。

enableExternalConfiguration [boolean]​

是否启用从外部源（例如 classpath 中的 sentry.properties）加载配置。设置为 true 后，SDK 会 自动加载环境特定的配置文件。

maxCacheItems [number]​

最大缓存事件数量，超过后会丢弃旧事件。不设置时 SDK 默认为 30。

flushTimeoutMillis [long]​

刷新待发送事件时的等待时间，单位毫秒。用于在写入器关闭时控制阻塞时长。

maxQueueSize [number]​

事件刷新到磁盘前的最大队列大小。当事件产生速度快于网络发送速度时，可以适当调大该值。

common options​

接收器插件通用参数，详见 Sink 常见选项。

任务示例​

简单示例​

sink {
  Sentry {
    dsn = "https://xxx@sentry.xxx.com:9999/6"
    enableExternalConfiguration = true
    maxCacheItems = 1000
    flushTimeoutMillis = 15000
    env = "prod"
  }
}

配合上游源使用​

将 fake 源产生的行数据转发到 Sentry 的典型端到端作业。

env {
  parallelism = 1
  job.mode = "BATCH"
}

source {
  FakeSource {
    schema = {
      fields {
        event = string
        severity = string
      }
    }
    rows = [
      { kind = "INSERT", fields = ["service-restart", "warning"] }
    ]
  }
}

sink {
  Sentry {
    dsn = "https://xxx@sentry.xxx.com:9999/6"
    env = "prod"
    release = "seatunnel-job@1.0.0"
    enableExternalConfiguration = false
    maxCacheItems = 1000
    flushTimeoutMillis = 15000
  }
}

变更日志​

Change Log
ChangeCommitVersion
[improve] sentry options (#9261)https://github.com/apache/seatunnel/commit/4a2f3fa9152.3.11
[Feature][Restapi] Allow metrics information to be associated to logical plan nodes (#7786)https://github.com/apache/seatunnel/commit/6b7c53d03c2.3.9
[Improve] Remove use SeaTunnelSink::getConsumedType method and mark it as deprecated (#5755)https://github.com/apache/seatunnel/commit/8de74081002.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
[Hotfix][OptionRule] Fix option rule about all connectors (#3592)https://github.com/apache/seatunnel/commit/226dc6a1192.3.0
[Improve][Connector-V2][Sentry] Unified exception for sentry sink connector (#3513)https://github.com/apache/seatunnel/commit/94b472b8062.3.0
[Connector][Dependency] Add Miss Dependency Cassandra And Change Kudu Plugin Name (#3432)https://github.com/apache/seatunnel/commit/6ac6a0a0cd2.3.0
[Feature][Sentry Sink V2] Add Sentry Sink Option Rules (#3318)https://github.com/apache/seatunnel/commit/850f4838162.3.0
[Feature][Connector-V2] Add sentry sink connector #2244 (#2584)https://github.com/apache/seatunnel/commit/9fd40390a72.2.0-beta