Amazon Appflow Update: Salesforce connector creation with customer pr…

…ovided client id and client secret, incremental pull configuration, salesforce upsert write operations and execution ID when on-demand flows are executed.
aws · Oct 22, 2020 · 6c8f85d · 6c8f85d
1 parent 840c22a
commit 6c8f85d
Show file tree

Hide file tree

Showing 2 changed files with 86 additions and 10 deletions.
diff --git a/.changes/next-release/feature-AmazonAppflow-23b9414.json b/.changes/next-release/feature-AmazonAppflow-23b9414.json
@@ -0,0 +1,5 @@
+{
+    "type": "feature",
+    "category": "Amazon Appflow",
+    "description": "Salesforce connector creation with customer provided client id and client secret, incremental pull configuration, salesforce upsert write operations and execution ID when on-demand flows are executed."
+}
diff --git a/services/appflow/src/main/resources/codegen-resources/service-2.json b/services/appflow/src/main/resources/codegen-resources/service-2.json
@@ -420,6 +420,13 @@
       "max":512,
       "pattern":".*"
     },
+    "ClientCredentialsArn":{
+      "type":"string",
+      "max":2048,
+      "min":20,
+      "pattern":"arn:aws:secretsmanager:.*:[0-9]+:.*",
+      "sensitive":true
+    },
     "ClientId":{
       "type":"string",
       "max":512,
@@ -1138,6 +1145,11 @@
       "documentation":"<p> The properties that are applied when Datadog is being used as a source. </p>"
     },
     "Date":{"type":"timestamp"},
+    "DatetimeTypeFieldName":{
+      "type":"string",
+      "max":256,
+      "pattern":".*"
+    },
     "DeleteConnectorProfileRequest":{
       "type":"structure",
       "required":["connectorProfileName"],
@@ -1424,6 +1436,14 @@
         "isUpsertable":{
           "shape":"Boolean",
           "documentation":"<p> Specifies if the flow run can either insert new rows in the destination field if they do not already exist, or update them if they do. </p>"
+        },
+        "isUpdatable":{
+          "shape":"Boolean",
+          "documentation":"<p> Specifies whether the field can be updated during an <code>UPDATE</code> or <code>UPSERT</code> write operation. </p>"
+        },
+        "supportedWriteOperations":{
+          "shape":"SupportedWriteOperationList",
+          "documentation":"<p> A list of supported write operations. For each write operation listed, this field can be used in <code>idFieldNames</code> when that write operation is present as a destination option. </p>"
         }
       },
       "documentation":"<p> The properties that can be applied to a field when connector is being used as a destination. </p>"
@@ -1809,7 +1829,7 @@
         },
         "clientSecret":{
           "shape":"ClientSecret",
-          "documentation":"<p> The client secret used by the oauth client to authenticate to the authorization server. </p>"
+          "documentation":"<p> The client secret used by the OAuth client to authenticate to the authorization server. </p>"
         },
         "accessToken":{
           "shape":"AccessToken",
@@ -1821,7 +1841,7 @@
         },
         "oAuthRequest":{
           "shape":"ConnectorOAuthRequest",
-          "documentation":"<p> The oauth requirement needed to request security tokens from the connector endpoint. </p>"
+          "documentation":"<p> The OAuth requirement needed to request security tokens from the connector endpoint. </p>"
         }
       },
       "documentation":"<p> The connector-specific profile credentials required by Google Analytics. </p>"
@@ -1858,11 +1878,28 @@
       "max":128,
       "pattern":"\\S+"
     },
+    "IdFieldNameList":{
+      "type":"list",
+      "member":{"shape":"Name"},
+      "documentation":"<p> A list of field names that can be used as an ID field when performing a write operation. </p>",
+      "max":1,
+      "min":0
+    },
     "Identifier":{
       "type":"string",
       "max":128,
       "pattern":"\\S+"
     },
+    "IncrementalPullConfig":{
+      "type":"structure",
+      "members":{
+        "datetimeTypeFieldName":{
+          "shape":"DatetimeTypeFieldName",
+          "documentation":"<p> A field that specifies the date time or timestamp field as the criteria to use when importing incremental records from the source. </p>"
+        }
+      },
+      "documentation":"<p> Specifies the configuration used when importing incremental records from the source. </p>"
+    },
     "InforNexusConnectorOperator":{
       "type":"string",
       "enum":[
@@ -2078,15 +2115,15 @@
         },
         "clientSecret":{
           "shape":"ClientSecret",
-          "documentation":"<p> The client secret used by the oauth client to authenticate to the authorization server. </p>"
+          "documentation":"<p> The client secret used by the OAuth client to authenticate to the authorization server. </p>"
         },
         "accessToken":{
           "shape":"AccessToken",
           "documentation":"<p> The credentials used to access protected Marketo resources. </p>"
         },
         "oAuthRequest":{
           "shape":"ConnectorOAuthRequest",
-          "documentation":"<p> The oauth requirement needed to request security tokens from the connector endpoint. </p>"
+          "documentation":"<p> The OAuth requirement needed to request security tokens from the connector endpoint. </p>"
         }
       },
       "documentation":"<p> The connector-specific profile credentials required by Marketo. </p>"
@@ -2472,7 +2509,11 @@
         },
         "oAuthRequest":{
           "shape":"ConnectorOAuthRequest",
-          "documentation":"<p> The oauth requirement needed to request security tokens from the connector endpoint. </p>"
+          "documentation":"<p> The OAuth requirement needed to request security tokens from the connector endpoint. </p>"
+        },
+        "clientCredentialsArn":{
+          "shape":"ClientCredentialsArn",
+          "documentation":"<p> The secret manager ARN, which contains the client ID and client secret of the connected app. </p>"
         }
       },
       "documentation":"<p> The connector-specific profile credentials required when using Salesforce. </p>"
@@ -2499,9 +2540,17 @@
           "shape":"Object",
           "documentation":"<p> The object specified in the Salesforce flow destination. </p>"
         },
+        "idFieldNames":{
+          "shape":"IdFieldNameList",
+          "documentation":"<p> The name of the field that Amazon AppFlow uses as an ID when performing a write operation such as update or delete. </p>"
+        },
         "errorHandlingConfig":{
           "shape":"ErrorHandlingConfig",
           "documentation":"<p> The settings that determine how Amazon AppFlow handles an error when placing data in the Salesforce destination. For example, this setting would determine if the flow should fail after one insertion error, or continue and attempt to insert every record regardless of the initial failure. <code>ErrorHandlingConfig</code> is a part of the destination connector details. </p>"
+        },
+        "writeOperationType":{
+          "shape":"WriteOperationType",
+          "documentation":"<p> This specifies the type of write operation to be performed in Salesforce. When the value is <code>UPSERT</code>, then <code>idFieldNames</code> is required. </p>"
         }
       },
       "documentation":"<p> The properties that are applied when Salesforce is being used as a destination. </p>"
@@ -2759,15 +2808,15 @@
         },
         "clientSecret":{
           "shape":"ClientSecret",
-          "documentation":"<p> The client secret used by the oauth client to authenticate to the authorization server. </p>"
+          "documentation":"<p> The client secret used by the OAuth client to authenticate to the authorization server. </p>"
         },
         "accessToken":{
           "shape":"AccessToken",
           "documentation":"<p> The credentials used to access protected Slack resources. </p>"
         },
         "oAuthRequest":{
           "shape":"ConnectorOAuthRequest",
-          "documentation":"<p> The oauth requirement needed to request security tokens from the connector endpoint. </p>"
+          "documentation":"<p> The OAuth requirement needed to request security tokens from the connector endpoint. </p>"
         }
       },
       "documentation":"<p> The connector-specific profile credentials required when using Slack. </p>"
@@ -2995,6 +3044,10 @@
         "sourceConnectorProperties":{
           "shape":"SourceConnectorProperties",
           "documentation":"<p> Specifies the information that is required to query a particular source connector. </p>"
+        },
+        "incrementalPullConfig":{
+          "shape":"IncrementalPullConfig",
+          "documentation":"<p> Defines the configuration for a scheduled incremental data pull. If a valid configuration is provided, the fields specified in the configuration are used when querying for the incremental data pull. </p>"
         }
       },
       "documentation":"<p> Contains information about the configuration of the source connector used in the flow. </p>"
@@ -3024,6 +3077,10 @@
         "flowStatus":{
           "shape":"FlowStatus",
           "documentation":"<p> Indicates the current status of the flow. </p>"
+        },
+        "executionId":{
+          "shape":"ExecutionId",
+          "documentation":"<p> Returns the internal execution ID of an on-demand flow when the flow is started. For scheduled or event-triggered flows, this value is null. </p>"
         }
       }
     },
@@ -3070,6 +3127,10 @@
       "type":"list",
       "member":{"shape":"Value"}
     },
+    "SupportedWriteOperationList":{
+      "type":"list",
+      "member":{"shape":"WriteOperationType"}
+    },
     "TagKey":{
       "type":"string",
       "max":128,
@@ -3171,7 +3232,8 @@
     },
     "Timezone":{
       "type":"string",
-      "max":256
+      "max":256,
+      "pattern":".*"
     },
     "TrendmicroConnectorOperator":{
       "type":"string",
@@ -3471,6 +3533,15 @@
       "max":512,
       "pattern":"[\\s\\w/!@#+=.-]*"
     },
+    "WriteOperationType":{
+      "type":"string",
+      "documentation":"<p> The possible write operations in the destination connector. When this value is not provided, this defaults to the <code>INSERT</code> operation. </p>",
+      "enum":[
+        "INSERT",
+        "UPSERT",
+        "UPDATE"
+      ]
+    },
     "ZendeskConnectorOperator":{
       "type":"string",
       "enum":[
@@ -3503,15 +3574,15 @@
         },
         "clientSecret":{
           "shape":"ClientSecret",
-          "documentation":"<p> The client secret used by the oauth client to authenticate to the authorization server. </p>"
+          "documentation":"<p> The client secret used by the OAuth client to authenticate to the authorization server. </p>"
         },
         "accessToken":{
           "shape":"AccessToken",
           "documentation":"<p> The credentials used to access protected Zendesk resources. </p>"
         },
         "oAuthRequest":{
           "shape":"ConnectorOAuthRequest",
-          "documentation":"<p> The oauth requirement needed to request security tokens from the connector endpoint. </p>"
+          "documentation":"<p> The OAuth requirement needed to request security tokens from the connector endpoint. </p>"
         }
       },
       "documentation":"<p> The connector-specific profile credentials required when using Zendesk. </p>"