Overview
Configuration is provided for establishing connections with the Amazon DynamoDB service. The configuration is used in the REST Connection Manager.
Setup
Press 
icon to get more information about the connection parameters.
Obtain data
Use REST Source component to get data from service resource.
Insert data
Use REST Destination component to insert data into service resource.
Quick Start
In this task, we will show you step-by-step how to create a connection to Amazon DynamoDB Service REST API using COZYROC's REST Connection Manager.
Step 1. Run "Visual Studio" under "Administrator account". Right click on Connection managers tab and select New Connection. In Add SSIS Connection Manager dialog scroll down, select REST connection manager from the list and then click Add.
Step 2. From drop-down menu Configuration select Amazon DynamoDB. Enter a valid endpoint name for your Amazon DynamoDB region for the Server parameter, as well as Access Key and Secret Key.
Step 3. Press Test Connection button. When you see Test Connection succeeded, click OK.
Congratulations! You have successfully created a connection to Amazon DynamoDB REST API using COZYROC's REST Connection Manager.
In this guide, we will show you how to read data from Amazon DynamoDB Service resource using the COZYROC REST Source component.
Step 1. Select an existing or create a new "Data Flow Task".
Step 2. Open "SSIS Toolbox" and drag and drop COZYROC "REST Source" component.
Step 3. Double click on the "REST Source" component and select Amazon DynamoDB connection from the list. Select from available Amazon DynamoDB resources listed in the second list below.
Optionally you can add PartiQL parameter to define PartiQL statement to extract data from the resource.
Step 4. Click on the "Columns" tab and select Amazon DynamoDB resource columns you want to read.
Step 5. Click "Preview" tab to make sure all necessary resource columns are included.
Bravo! You have now learned how to read data from Amazon DynamoDB service.
In this guide, we will show how to write data to the Amazon DynamoDB service resource using the COZYROC REST Destination component.
Step 1. Select an existing or create a new "Data Flow Task".
Step 2. Open the "SSIS Toolbox" and drag and drop COZYROC "REST Destination" component.
Step 3. Double click on the "REST Destination" component and select Amazon DynamoDB connection from the list. Also, select resource action and Amazon DynamoDB resource you want to work on.
Step 4. Click on the "Mapping" tab and map the input columns for the process you are configuring.
If you want to provide input for other resource composite objects, change the input above and map the columns.
Done. You have now learned how to write data into the Amazon DynamoDB Service resource.
Configuration
Base URL address: https://dynamodb.[REGION].amazonaws.com.
- Amazon AWS Signature v4
-
The authentication uses a parameters-based authentication.
The authentication has the following user-defined parameters:
- Access Key: Required. Specify access key.
- Secret Key: Required. Specify secret key.
The following request parameters will be automatically processed during the authentication process:
-
Authorization:
{{=aws4s.authorizationHeader (request, connection)}} -
Host:
{{=request.signedRequest.headers['Host']}} -
X-Amz-Content-Sha256:
{{=request.signedRequest.headers['X-Amz-Content-Sha256']}} -
X-Amz-Date:
{{=request.signedRequest.headers['X-Amz-Date']}} -
Content-Type:
{{=request.signedRequest.headers['Content-Type']}} -
X-Amz-Target:
Documentation: https://docs.aws.amazon.com/general/latest/gr/signature-version-4.html.
- Amazon AWS Signature v4 Temporary Credentials
-
The authentication uses a parameters-based authentication.
The authentication has the following user-defined parameters:
- Access Key: Required. Specify access key.
- Secret Key: Required. Specify secret key.
- Session Token: Required. Specify session token.
The following request parameters will be automatically processed during the authentication process:
-
Authorization:
{{=aws4s.authorizationHeader (request, connection)}} -
Host:
{{=request.signedRequest.headers['Host']}} -
X-Amz-Content-Sha256:
{{=request.signedRequest.headers['X-Amz-Content-Sha256']}} -
X-Amz-Date:
{{=request.signedRequest.headers['X-Amz-Date']}} -
Content-Type:
{{=request.signedRequest.headers['Content-Type']}} -
X-Amz-Target:
-
X-Amz-Security-Token:
{{=request.signedRequest.headers['X-Amz-Security-Token']}}
Documentation: https://docs.aws.amazon.com/IAM/latest/UserGuide/id_credentials_temp_use-resources.html.
- [Read] action
-
The result is extracted from:{{=DynamoDB.getTableValues(resource.external.name, parameters)}}.The action has the following user-defined parameters:
- Query: Specify PartiQL Statement. Optional.
- [Create] action
-
Endpoint URL address:
/.The following request parameters will be automatically processed:
-
X-Amz-Target:
DynamoDB_20120810.PutItem -
application/x-amz-json-1.1:
{{={ TableName: resource.external.name, Item: DynamoDB.toDynamoDBValue(item).M } }}
Documentation: https://docs.aws.amazon.com/amazondynamodb/latest/APIReference/API_PutItem.html.
-
X-Amz-Target:
- [Update] action
-
Endpoint URL address:
.
The result is extracted from:{{= DynamoDB.updateTable(resource.external.name, item, true) }}.
- [Upsert] action
-
Endpoint URL address:
.
The result is extracted from:{{= DynamoDB.updateTable(resource.external.name, item) }}.
- [Delete] action
-
Endpoint URL address:
/.The following request parameters will be automatically processed:
-
X-Amz-Target:
DynamoDB_20120810.DeleteItem -
application/x-amz-json-1.1:
{{={ TableName: resource.external.name, Key: DynamoDB.getPrimaryKeys(resource.external.name, item) } }}
Documentation: https://docs.aws.amazon.com/amazondynamodb/latest/APIReference/API_DeleteItem.html.
-
X-Amz-Target:
- [External]
-
The external fields list is extracted from:
{{=DynamoDB.getTableFields(resource.external.name, parameters)}}.
The external resource list is extracted from: {{= DynamoDB.getTables() }}.
Based on resource template Base.
- [Read] action
-
The action uses POST method.
The result is paginated.The following request parameters will be automatically processed:
-
application/x-amz-json-1.1:
{{=_.extend({ MaxResults: parameters.batchSize, NextToken: parameters.iterator }, parameters)}}
-
application/x-amz-json-1.1:
- [Create] action
-
The action uses POST method.The following request parameters will be automatically processed:
-
X-Amz-Target:
{{=parameters.get('X-Amz-Target')}} -
application/x-amz-json-1.1:
{{=item}} -
_includeUserParameters:
{{=parameters}}
-
X-Amz-Target:
- [Update] action
-
The action uses POST method.The following request parameters will be automatically processed:
-
X-Amz-Target:
{{=parameters.get('X-Amz-Target')}} -
application/x-amz-json-1.1:
{{=item}} -
_includeUserParameters:
{{=parameters}}
-
X-Amz-Target:
- [Delete] action
-
The action uses POST method.The following request parameters will be automatically processed:
-
X-Amz-Target:
{{=parameters.get('X-Amz-Target')}} -
application/x-amz-json-1.1:
{{=item}} -
_includeUserParameters:
{{=parameters}}
-
X-Amz-Target:
- ShortText
Data type: DT_WSTR ( length 255 )
- Numeric
Data type: DT_R8
- Boolean
Data type: DT_BOOL
Knowledge Base
What's New
- New: Introduced connection.
COZYROC SSIS+ Components Suite is free for testing in your development environment.
A licensed version can be deployed on-premises, on Azure-SSIS IR and on COZYROC Cloud.