UpdateFlow - Amazon Appflow

UpdateFlow

Updates an existing flow.

Request Syntax

POST /update-flow HTTP/1.1 Content-type: application/json { "description": "string", "destinationFlowConfigList": [ { "connectorProfileName": "string", "connectorType": "string", "destinationConnectorProperties": { "EventBridge": { "errorHandlingConfig": { "bucketName": "string", "bucketPrefix": "string", "failOnFirstDestinationError": boolean }, "object": "string" }, "Redshift": { "bucketPrefix": "string", "errorHandlingConfig": { "bucketName": "string", "bucketPrefix": "string", "failOnFirstDestinationError": boolean }, "intermediateBucketName": "string", "object": "string" }, "S3": { "bucketName": "string", "bucketPrefix": "string", "s3OutputFormatConfig": { "aggregationConfig": { "aggregationType": "string" }, "fileType": "string", "prefixConfig": { "prefixFormat": "string", "prefixType": "string" } } }, "Salesforce": { "errorHandlingConfig": { "bucketName": "string", "bucketPrefix": "string", "failOnFirstDestinationError": boolean }, "idFieldNames": [ "string" ], "object": "string", "writeOperationType": "string" }, "Snowflake": { "bucketPrefix": "string", "errorHandlingConfig": { "bucketName": "string", "bucketPrefix": "string", "failOnFirstDestinationError": boolean }, "intermediateBucketName": "string", "object": "string" }, "Upsolver": { "bucketName": "string", "bucketPrefix": "string", "s3OutputFormatConfig": { "aggregationConfig": { "aggregationType": "string" }, "fileType": "string", "prefixConfig": { "prefixFormat": "string", "prefixType": "string" } } } } } ], "flowName": "string", "sourceFlowConfig": { "connectorProfileName": "string", "connectorType": "string", "incrementalPullConfig": { "datetimeTypeFieldName": "string" }, "sourceConnectorProperties": { "Amplitude": { "object": "string" }, "Datadog": { "object": "string" }, "Dynatrace": { "object": "string" }, "GoogleAnalytics": { "object": "string" }, "InforNexus": { "object": "string" }, "Marketo": { "object": "string" }, "S3": { "bucketName": "string", "bucketPrefix": "string" }, "Salesforce": { "enableDynamicFieldUpdate": boolean, "includeDeletedRecords": boolean, "object": "string" }, "ServiceNow": { "object": "string" }, "Singular": { "object": "string" }, "Slack": { "object": "string" }, "Trendmicro": { "object": "string" }, "Veeva": { "object": "string" }, "Zendesk": { "object": "string" } } }, "tasks": [ { "connectorOperator": { "Amplitude": "string", "Datadog": "string", "Dynatrace": "string", "GoogleAnalytics": "string", "InforNexus": "string", "Marketo": "string", "S3": "string", "Salesforce": "string", "ServiceNow": "string", "Singular": "string", "Slack": "string", "Trendmicro": "string", "Veeva": "string", "Zendesk": "string" }, "destinationField": "string", "sourceFields": [ "string" ], "taskProperties": { "string" : "string" }, "taskType": "string" } ], "triggerConfig": { "triggerProperties": { "Scheduled": { "dataPullMode": "string", "scheduleEndTime": number, "scheduleExpression": "string", "scheduleStartTime": number, "timezone": "string" } }, "triggerType": "string" } }

URI Request Parameters

The request does not use any URI parameters.

Request Body

The request accepts the following data in JSON format.

description

A description of the flow.

Type: String

Length Constraints: Maximum length of 2048.

Pattern: [\w!@#\-.?,\s]*

Required: No

destinationFlowConfigList

The configuration that controls how Amazon AppFlow transfers data to the destination connector.

Type: Array of DestinationFlowConfig objects

Required: Yes

flowName

The specified name of the flow. Spaces are not allowed. Use underscores (_) or hyphens (-) only.

Type: String

Length Constraints: Maximum length of 256.

Pattern: [a-zA-Z0-9][\w!@#.-]+

Required: Yes

sourceFlowConfig

Contains information about the configuration of the source connector used in the flow.

Type: SourceFlowConfig object

Required: No

tasks

A list of tasks that Amazon AppFlow performs while transferring the data in the flow run.

Type: Array of Task objects

Required: Yes

triggerConfig

The trigger settings that determine how and when the flow runs.

Type: TriggerConfig object

Required: Yes

Response Syntax

HTTP/1.1 200 Content-type: application/json { "flowStatus": "string" }

Response Elements

If the action is successful, the service sends back an HTTP 200 response.

The following data is returned in JSON format by the service.

flowStatus

Indicates the current status of the flow.

Type: String

Valid Values: Active | Deprecated | Deleted | Draft | Errored | Suspended

Errors

For information about the errors that are common to all actions, see Common Errors.

ConflictException

There was a conflict when processing the request (for example, a flow with the given name already exists within the account. Check for conflicting resource names and try again.

HTTP Status Code: 409

ConnectorAuthenticationException

An error occurred when authenticating with the connector endpoint.

HTTP Status Code: 401

ConnectorServerException

An error occurred when retrieving data from the connector endpoint.

HTTP Status Code: 400

InternalServerException

An internal service error occurred during the processing of your request. Try again later.

HTTP Status Code: 500

ResourceNotFoundException

The resource specified in the request (such as the source or destination connector profile) is not found.

HTTP Status Code: 404

ServiceQuotaExceededException

The request would cause a service quota (such as the number of flows) to be exceeded.

HTTP Status Code: 402

ValidationException

The request has invalid or missing parameters.

HTTP Status Code: 400

Examples

Salesforce

This example shows a sample request for the UpdateFlow API using Salesforce.

Sample Request

{ "flowName": "testFlow-newpayload", // flow that you created as part of createFlow above "description": "TestFlow", "triggerConfig": { "triggerType": "OnDemand" }, "sourceFlowConfig": { "connectorType": "Salesforce", "connectorProfileName": "Connector_Profile_Name", "sourceConnectorProperties": { "salesforce": { "object": "account" } } }, "destinationFlowConfigList": [ { "connectorType": "S3", "connectorProfileName": "Test", "destinationConnectorProperties": { "s3": { "bucketName": "Bucket_Name_value", "bucketKey": "Bucket_Name_value" } } } ], "tasks": [ { "sourceFields": [ "CreatedDate" ], "taskProperties": { }, "destinationField": "CreatedDate", "taskType": "Map" }, { "destinationField": "LastActivityDate", "sourceFields": [ "LastActivityDate" ], "taskProperties": { }, "taskType": "Map" } ] }

Zendesk

This example shows a sample request for the UpdateFlow API using Zendesk.

Sample Request

{ "useDefaultEncryption": false, "flowName": "testFlowZendesk", "description": "TestFlow", "triggerConfig": { "triggerType": "OnDemand" }, "sourceFlowConfig": { "connectorType": "Zendesk", "connectorProfileName": "connector-profile-name", "sourceConnectorProperties": { "zendesk": { "object": "tickets" } } }, "destinationFlowConfigList": [ { "connectorType": "S3", "connectorProfileName": "Test", "destinationConnectorProperties": { "s3": { "bucketName": "Bucket_Name_Value", "bucketKey": "Bucket_Name_Value" } } } ], "tasks": [ { "destinationField": "url", "sourceFields": [ "url" ], "taskProperties": { "SOURCE_DATA_TYPE": "integer" }, "taskType": "Map" } ] }

Google Analytics

This example shows a sample request for the UpdateFlow API using Google Analytics.

Sample Request

{ "useDefaultEncryption": false, "flowName": "testFlowGAnalytics", "description": "TestFlow", "triggerConfig": { "triggerType": "OnDemand" }, "sourceFlowConfig": { "connectorType": "Googleanalytics", "connectorProfileName": "connector-profile-name", "sourceConnectorProperties": { "googleanalytics": { "object": "Object_ID" } } }, "destinationFlowConfigList": [ { "connectorType": "S3", "connectorProfileName": "Test", "destinationConnectorProperties": { "s3": { "bucketName": "Bucket_Name_Value", "bucketKey": "Bucket_Name_Value" } } } ], "tasks": [ { "destinationField": "url", "sourceFields": [ "url" ], "taskProperties": { "SOURCE_DATA_TYPE": "integer" }, "taskType": "Map" } ] }

Marketo

This example shows a sample request for the UpdateFlow API using Marketo.

Sample Request

{ "flowName": "testMarketo", "description": "TestFlow", "triggerConfig": { "triggerType": "OnDemand" }, "sourceFlowConfig": { "connectorType": "Marketo", "connectorProfileName": "Connector-profile-new", "sourceConnectorProperties": { "marketo": { "object": "leads" } } }, "destinationFlowConfigList": [ { "connectorType": "S3", "connectorProfileName": "Test", "destinationConnectorProperties": { "s3": { "bucketName": "Bucket_Name_Value", "bucketKey": "Bucket_Name_Value" } } } ], "tasks": [ { "connectorOperator": { "marketo":"BETWEEN" }, "sourceFields": [ "updatedAt" ], "taskProperties": { "DATA_TYPE": "datetime", "LOWER_BOUND": "Lower_Bound_value", "UPPER_BOUND": "Upper_Bound_value" }, "taskType": "Filter" }, { "destinationField": "company", "sourceFields": [ "company" ], "taskProperties": { "SOURCE_DATA_TYPE": "string" }, "taskType": "Map" } ] }

See Also

For more information about using this API in one of the language-specific AWS SDKs, see the following: