DynamoDB
Kubemq dynamodb target connector allows services using kubemq server to access aws dynamodb service.
Prerequisites
The following required to run the aws-dynamodb target connector:
kubemq cluster
aws account with dynamodb active service
kubemq-source deployment
Configuration
dynamodb target connector configuration properties:
Properties Key | Required | Description | Example |
aws_key | yes | aws key | aws key supplied by aws |
aws_secret_key | yes | aws secret key | aws secret key supplied by aws |
region | yes | region | aws region |
token | no | aws token ("default" empty string | aws token |
Example:
Usage
List Tables
list all tables under dynamodb.
List Tables:
Metadata Key | Required | Description | Possible values |
method | yes | type of method | "list_tables" |
Example:
Create Table
create a new table under dynamodb.
Create Table:
Metadata Key | Required | Description | Possible values |
method | yes | type of method | "create_table" |
data | yes | dynamodb.CreateTableInput as json | "string" |
Example:
Delete Table
delete a table under dynamodb.
Delete Table:
Metadata Key | Required | Description | Possible values |
method | yes | type of method | "delete_table" |
table_name | yes | table name to delete | "string" |
Example:
Insert Item
insert item to table under dynamodb.
Insert Item :
Metadata Key | Required | Description | Possible values |
method | yes | type of method | "insert_item" |
table_name | yes | table name to delete | "string" |
data | yes | dynamodb.AttributeValue as json | "string" |
Example:
Get Item
get an item from a table under dynamodb.
Get Item :
Metadata Key | Required | Description | Possible values |
method | yes | type of method | "get_item" |
data | yes | dynamodb.GetItemInput as json | "string" |
Example:
Update Item
update an item from a table under dynamodb.
Update Item :
Metadata Key | Required | Description | Possible values |
method | yes | type of method | "update_item" |
data | yes | dynamodb.UpdateItemInput as json | "string" |
Example:
Delete Item
delete an item from a table under dynamodb.
Delete Item :
Metadata Key | Required | Description | Possible values |
method | yes | type of method | "delete_item" |
data | yes | dynamodb.DeleteItemInput as json | "string" |
Example:
Last updated