跳到主要内容
版本:2.3.10

AmazonDynamoDB

Amazon DynamoDB 接收器连接器

描述

将数据写入 Amazon DynamoDB

关键特性

选项

名称类型必需默认值
urlstring-
regionstring-
access_key_idstring-
secret_access_keystring-
tablestring-
batch_sizestring25
common-options-

url [string]

要写入Amazon DynamoDB的URL.

region [string]

Amazon DynamoDB 的分区.

accessKeyId [string]

Amazon DynamoDB的访问id.

secretAccessKey [string]

Amazon DynamoDB的访问密钥.

table [string]

Amazon DynamoDB 的表名.

常见选项

Sink插件常用参数,请参考 Sink Common Options 了解详细信息.

示例

Amazondynamodb {
url = "http://127.0.0.1:8000"
region = "us-east-1"
accessKeyId = "dummy-key"
secretAccessKey = "dummy-secret"
table = "TableName"
}

变更日志

Change Log
ChangeCommitVersion
[Fix] Fix error log name for SourceSplitEnumerator implements class (#8817)https://github.com/apache/seatunnel/commit/55ed90eca2.3.10
[Improve] restruct connector common options (#8634)https://github.com/apache/seatunnel/commit/f3499a6ee2.3.10
[improve] update amazondynamodb connector (#8601)https://github.com/apache/seatunnel/commit/a69efca0f2.3.10
[Feature][Restapi] Allow metrics information to be associated to logical plan nodes (#7786)https://github.com/apache/seatunnel/commit/6b7c53d032.3.9
[Feature][Doris] Add Doris type converter (#6354)https://github.com/apache/seatunnel/commit/5189991842.3.6
[Feature][Core] Upgrade flink source translation (#5100)https://github.com/apache/seatunnel/commit/5aabb14a92.3.4
[Improve][Common] Introduce new error define rule (#5793)https://github.com/apache/seatunnel/commit/9d1b2582b2.3.4
[Improve] Code clean for AmazonDynamoDB connector (#5791)https://github.com/apache/seatunnel/commit/a17dd7afc2.3.4
[Improve] Remove use SeaTunnelSink::getConsumedType method and mark it as deprecated (#5755)https://github.com/apache/seatunnel/commit/8de7408102.3.4
[connector-v2] add amazondynamicdb source split (#5275)https://github.com/apache/seatunnel/commit/740c144222.3.4
Support config column/primaryKey/constraintKey in schema (#5564)https://github.com/apache/seatunnel/commit/eac76b4e52.3.4
[Improve]Remove scheduler in Dynamodb sink (#5248)https://github.com/apache/seatunnel/commit/9e033a8242.3.4
[Improve][CheckStyle] Remove useless 'SuppressWarnings' annotation of checkstyle. (#5260)https://github.com/apache/seatunnel/commit/51c0d709b2.3.4
[Bugfix][AmazonDynamoDB] Fix the problem that all table data cannot be obtained (#5146)https://github.com/apache/seatunnel/commit/09995159a2.3.3
Merge branch 'dev' into merge/cdchttps://github.com/apache/seatunnel/commit/4324ee1912.3.1
[Improve][Project] Code format with spotless plugin.https://github.com/apache/seatunnel/commit/423b583032.3.1
[improve][api] Refactoring schema parse (#4157)https://github.com/apache/seatunnel/commit/b2f573a132.3.1
[Improve][build] Give the maven module a human readable name (#4114)https://github.com/apache/seatunnel/commit/d7cd601052.3.1
[Improve][Project] Code format with spotless plugin. (#4101)https://github.com/apache/seatunnel/commit/a2ab166562.3.1
[Feature][Connector] add get source method to all source connector (#3846)https://github.com/apache/seatunnel/commit/417178fb82.3.1
[Feature][API & Connector & Doc] add parallelism and column projection interface (#3829)https://github.com/apache/seatunnel/commit/b9164b8ba2.3.1
[Hotfix][API] env required option can not set default value (#3584)https://github.com/apache/seatunnel/commit/c5a23024f2.3.0
[Feature][Connector-V2][AmazonDynamoDB] Add Factory for AmazonDynamoDB (#3348)https://github.com/apache/seatunnel/commit/a0068efdb2.3.0
[Improve][Connector-V2][AmazonDynamoDB] Unified exception for AmazonDynamoDB source & sink connector (#3333)https://github.com/apache/seatunnel/commit/17bc5adce2.3.0
[Connector-V2][Chore] Canonical name for AmazonDynamodb (#3321)https://github.com/apache/seatunnel/commit/e216eb9a62.3.0
[Feature][Connector-V2] [Amazondynamodb Connector]add amazondynamodb source & sink connnector (#3166)https://github.com/apache/seatunnel/commit/183bac02f2.3.0