Sentry

Description

Write SeaTunnel rows to Sentry as messages. Each row is sent through the Sentry SDK by calling Sentry.captureMessage(row.toString()).

Key features

• exactly-once

Options

name	type	required	default value	description
dsn	string	yes	-	Sentry DSN used by the SDK.
env	string	no	-	Sentry environment name.
release	string	no	-	Sentry release value.
cacheDirPath	string	no	-	Cache directory for offline Sentry events.
enableExternalConfiguration	boolean	no	-	Whether the Sentry SDK can load external configuration.
maxCacheItems	int	no	-	Maximum number of cached events.
flushTimeoutMillis	long	no	-	Time in milliseconds to wait while flushing pending events.
maxQueueSize	int	no	-	Maximum queue size before events are flushed to disk.
common-options		no	-	Sink plugin common parameters.

dsn [string]

The DSN tells the SDK where to send the events to.

env [string]

specify the environment

release [string]

specify the release

cacheDirPath [string]

the cache dir path for caching offline events

enableExternalConfiguration [boolean]

if loading properties from external sources is enabled.

maxCacheItems [number]

The max cache items for capping the number of events Default is 30

flushTimeoutMillis [long]

Controls how many milliseconds to wait while flushing pending events.

maxQueueSize [number]

Max queue size before flushing events/envelopes to the disk

common options

Sink plugin common parameters, please refer to Sink Common Options for details

Example

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

Changelog

Change Log

Change	Commit	Version
[improve] sentry options (#9261)	https://github.com/apache/seatunnel/commit/4a2f3fa915	2.3.11
[Feature][Restapi] Allow metrics information to be associated to logical plan nodes (#7786)	https://github.com/apache/seatunnel/commit/6b7c53d03c	2.3.9
[Improve] Remove use SeaTunnelSink::getConsumedType method and mark it as deprecated (#5755)	https://github.com/apache/seatunnel/commit/8de7408100	2.3.4
[Improve][build] Give the maven module a human readable name (#4114)	https://github.com/apache/seatunnel/commit/d7cd601051	2.3.1
[Improve][Project] Code format with spotless plugin. (#4101)	https://github.com/apache/seatunnel/commit/a2ab166561	2.3.1
[Hotfix][OptionRule] Fix option rule about all connectors (#3592)	https://github.com/apache/seatunnel/commit/226dc6a119	2.3.0
[Improve][Connector-V2][Sentry] Unified exception for sentry sink connector (#3513)	https://github.com/apache/seatunnel/commit/94b472b806	2.3.0
[Connector][Dependency] Add Miss Dependency Cassandra And Change Kudu Plugin Name (#3432)	https://github.com/apache/seatunnel/commit/6ac6a0a0cd	2.3.0
[Feature][Sentry Sink V2] Add Sentry Sink Option Rules (#3318)	https://github.com/apache/seatunnel/commit/850f483816	2.3.0
[Feature][Connector-V2] Add sentry sink connector #2244 (#2584)	https://github.com/apache/seatunnel/commit/9fd40390a7	2.2.0-beta