CreateFlow - Amazon Appflow


Enables your application to create a new flow using Amazon AppFlow. You must create a connector profile before calling this API. Please note that the Request Syntax below shows syntax for multiple destinations, however, you can only transfer data to one item in this list at a time. Amazon AppFlow does not currently support flows to multiple destinations at once.

Request Syntax

POST /create-flow HTTP/1.1 Content-type: application/json { "description": "string", "destinationFlowConfigList": [ { "connectorProfileName": "string", "connectorType": "string", "destinationConnectorProperties": { "CustomerProfiles": { "domainName": "string", "objectTypeName": "string" }, "EventBridge": { "errorHandlingConfig": { "bucketName": "string", "bucketPrefix": "string", "failOnFirstDestinationError": boolean }, "object": "string" }, "Honeycode": { "errorHandlingConfig": { "bucketName": "string", "bucketPrefix": "string", "failOnFirstDestinationError": boolean }, "object": "string" }, "LookoutMetrics": { }, "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", "kmsArn": "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" } } }, "tags": { "string" : "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", "firstExecutionFrom": number, "scheduleEndTime": number, "scheduleExpression": "string", "scheduleOffset": number, "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.


A description of the flow you want to create.

Type: String

Length Constraints: Maximum length of 2048.

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

Required: No


The configuration that controls how Amazon AppFlow places data in the destination connector.

Type: Array of DestinationFlowConfig objects

Required: Yes


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


The ARN (Amazon Resource Name) of the Key Management Service (KMS) key you provide for encryption. This is required if you do not want to use the Amazon AppFlow-managed KMS key. If you don't provide anything here, Amazon AppFlow uses the Amazon AppFlow-managed KMS key.

Type: String

Length Constraints: Minimum length of 20. Maximum length of 2048.

Pattern: arn:aws:kms:.*:[0-9]+:.*

Required: No


The configuration that controls how Amazon AppFlow retrieves data from the source connector.

Type: SourceFlowConfig object

Required: Yes


The tags used to organize, track, or control access for your flow.

Type: String to string map

Map Entries: Minimum number of 0 items. Maximum number of 50 items.

Key Length Constraints: Minimum length of 1. Maximum length of 128.

Key Pattern: ^(?!aws:)[a-zA-Z+-=._:/]+$

Value Length Constraints: Maximum length of 256.

Value Pattern: [\s\w+-=\.:/@]*

Required: No


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

Type: Array of Task objects

Required: Yes


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 { "flowArn": "string", "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.


The flow's Amazon Resource Name (ARN).

Type: String

Length Constraints: Maximum length of 512.

Pattern: arn:aws:appflow:.*:[0-9]+:.*


Indicates the current status of the flow.

Type: String

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


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


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


An error occurred when authenticating with the connector endpoint.

HTTP Status Code: 401


An error occurred when retrieving data from the connector endpoint.

HTTP Status Code: 400


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

HTTP Status Code: 500


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

HTTP Status Code: 404


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

HTTP Status Code: 402


The request has invalid or missing parameters.

HTTP Status Code: 400



This example shows a sample request for the CreateFlow API using Salesforce. If you see the error shown in the second sample, it is because of an expired access or refresh token. Retrieve a new access or refresh token to proceed.

Sample Request

{ "flowName": "testFlowSaleforce", "description": "TestFlow", "triggerConfig": { "triggerType": "Scheduled", "triggerProperties": { "scheduledTriggerProperties" : { "scheduleExpression" : "rate(1minutes)" } } }, "sourceFlowConfig": { "connectorType": "Salesforce", "connectorProfileName": "Connector_Profile_Name", "sourceConnectorProperties": { "salesforce": { "object": "account" } } }, "destinationFlowConfigList": [ { "connectorType": "S3", "destinationConnectorProperties": { "s3": { "bucketName": "BucketName", "bucketKey": "BucketKey" } } } ], "tasks": [ { "sourceFields": [ "CreatedDate" ], "taskProperties": { }, "destinationField": "CreatedDate", "taskType": "Map" }, { "destinationField": "LastActivityDate", "sourceFields": [ "LastActivityDate" ], "taskProperties": { }, "taskType": "Map" } ] }
{ "message": "Error while authenticating to connector" }


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

Sample Request

{ "useDefaultEncryption": false, "flowName": "testFlowZendesk", "description": "TestFlow", "triggerConfig": { "triggerType": "Scheduled", "triggerProperties": { "scheduledTriggerProperties" : { "scheduleExpression" : "rate(1minutes)" } } }, "sourceFlowConfig": { "connectorType": "Zendesk", "connectorProfileName": "connector-profile-name", "sourceConnectorProperties": { "zendesk": { "object": "tickets" } } }, "destinationFlowConfigList": [ { "connectorType": "S3", "connectorProfileName": "Test", "destinationConnectorProperties": { "s3": { "bucketName": "BucketName", "bucketKey": "BucketKey" } } } ], "tasks": [ { "destinationField": "url", "sourceFields": [ "url" ], "taskProperties": { "SOURCE_DATA_TYPE": "integer" }, "taskType": "Map" } ] }

Google Analytics

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

Sample Request

{ "useDefaultEncryption": false, "flowName": "testFlowGAnalytics", "description": "TestFlow", "triggerConfig": { "triggerType": "Scheduled", "triggerProperties": { "scheduledTriggerProperties" : { "scheduleExpression" : "rate(1minutes)" } } }, "sourceFlowConfig": { "connectorType": "Googleanalytics", "connectorProfileName": "connector-profile-name", "sourceConnectorProperties": { "googleanalytics": { "object": "ObjectID" } } }, "destinationFlowConfigList": [ { "connectorType": "S3", "connectorProfileName": "Test", "destinationConnectorProperties": { "s3": { "bucketName": "BucketName", "bucketKey": "BucketKey" } } } ], "tasks": [ { "destinationField": "url", "sourceFields": [ "url" ], "taskProperties": { "SOURCE_DATA_TYPE": "integer" }, "taskType": "Map" } ] }


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

Sample Request

{ "flowName": "testMarketo", "description": "TestFlow", "triggerConfig": { "triggerType": "Scheduled", "triggerProperties": { "scheduledTriggerProperties" : { "scheduleExpression" : "rate(1minutes)" } } }, "sourceFlowConfig": { "connectorType": "Marketo", "connectorProfileName": "Connector-profile-new", "sourceConnectorProperties": { "marketo": { "object": "leads" } } }, "destinationFlowConfigList": [ { "connectorType": "S3", "connectorProfileName": "Test", "destinationConnectorProperties": { "s3": { "bucketName": "BucketName", "bucketKey": "BucketKey" } } } ], "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" } ] }

Connection credentials

This Java example shows credentials associated with a connection. In this case, the example uses OAuth. These credentials are stored in secrets manager after the profile is created.

ConnectorProfileCredentials credentials = new ConnectorProfileCredentials().withSalesforce( new SalesforceConnectorProfileCredentials().withAccessToken(accessToken) .withRefreshToken(refreshToken));

Connection properties

This Java example shows other properties associated with a connection to Salesforce.

ConnectorProfileProperties properties = new ConnectorProfileProperties().withSalesforce( new SalesforceConnectorProfileProperties().withInstanceUrl(instanceUrl));

Connector profile creation

To create a flow, you must first create a connector profile. This Java example shows information about connecting to Salesforce.

amazonAppflow.createConnectorProfile(new CreateConnectorProfileRequest().withConnectorProfileConfig( new ConnectorProfileConfig().withConnectorProfileCredentials(credentials) .withConnectorProfileProperties(properties)) .withConnectorProfileName(salesforceProfileName) .withConnectorType(ConnectorType.Salesforce) .withConnectionMode(ConnectionMode.Public));

Source connection properties

This Java example shows properties for a source connection. Account is the object in Salesforce that we want to retrieve. You can find a list of all supported objects by using the listConnectorEntity API. The ConnectorProfileName is the connector profile, the creation of which is seen in the previous example.

SourceFlowConfig sourceFlowConfig = new SourceFlowConfig().withSourceConnectorProperties( new SourceConnectorProperties().withSalesforce(new SalesforceSourceProperties().withObject("Account"))) .withConnectorType(ConnectorType.Salesforce) .withConnectorProfileName(salesforceProfileName);

Destination connection properties

This Java example shows properties for a destination connection. Note that many AWS connectors such as Amazon S3 don't require a connector profile. Amazon Appflow accesses S3 buckets through a bucket resource policy, therefore a connector profile isn't needed.

DestinationFlowConfig destinationFlowConfig = new DestinationFlowConfig().withConnectorType(ConnectorType.S3) .withDestinationConnectorProperties(new DestinationConnectorProperties().withS3( new S3DestinationProperties().withBucketName(bucketName).withBucketPrefix("testPrefix")));


Tasks describe what to do with the data once it has been retrieved, but before it is sent to the destination. Most connectors require a projection task. A projection task describes what fields should be retrieved from the source object. Fields that can be retrieved can be discovered by making a call to the DescribeConnectorEntity API.

ask projectionTask = new Task().withTaskType(TaskType.Filter) .withConnectorOperator(new ConnectorOperator().withSalesforce(SalesforceConnectorOperator.PROJECTION)) .withSourceFields("Id", "Name");

Mapping task

Most flows also require at least one mapping task. Mapping tasks map a source field to a destination field. This Java example shows the mapping between the retrieved field, Id, to a new field, AccountId.

Task createdMappingTask = new Task().withTaskType(TaskType.Map) .withConnectorOperator(new ConnectorOperator().withSalesforce(SalesforceConnectorOperator.NO_OP)) .withSourceFields("Id") .withDestinationField("AccountId"); amazonAppflow.createFlow(new CreateFlowRequest().withFlowName(salesforceFlowName) .withTriggerConfig(new TriggerConfig().withTriggerType(TriggerType.OnDemand)) .withSourceFlowConfig(sourceFlowConfig) .withDestinationFlowConfigList(destinationFlowConfig) .withTasks(projectionTask, idMappingTask, createdMappingTask));

Sample imports

This Java example shows sample imports.

import; import; import; import; import; import; import; import; import; import; import; import; import; import; import; import; import; import; import; import; import; import; import; import;

See Also

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