Creates an integration workflow¶

Description¶

Creates an integration workflow. An integration workflow is an async process which ingests historic data and sets up an integration for ongoing updates. The supported Amazon AppFlow sources are Salesforce, ServiceNow, and Marketo.

Usage¶

customerprofiles_create_integration_workflow(DomainName, WorkflowType,
  IntegrationConfig, ObjectTypeName, RoleArn, Tags)

Arguments¶

DomainName

[required] The unique name of the domain.
WorkflowType

[required] The type of workflow. The only supported value is APPFLOW_INTEGRATION.
IntegrationConfig

[required] Configuration data for integration workflow.
ObjectTypeName

[required] The name of the profile object type.
RoleArn

[required] The Amazon Resource Name (ARN) of the IAM role. Customer Profiles assumes this role to create resources on your behalf as part of workflow execution.
Tags

The tags used to organize, track, or control access for this resource.

Value¶

A list with the following syntax:

list(
  WorkflowId = "string",
  Message = "string"
)

Request syntax¶

svc$create_integration_workflow(
  DomainName = "string",
  WorkflowType = "APPFLOW_INTEGRATION",
  IntegrationConfig = list(
    AppflowIntegration = list(
      FlowDefinition = list(
        Description = "string",
        FlowName = "string",
        KmsArn = "string",
        SourceFlowConfig = list(
          ConnectorProfileName = "string",
          ConnectorType = "Salesforce"|"Marketo"|"Zendesk"|"Servicenow"|"S3",
          IncrementalPullConfig = list(
            DatetimeTypeFieldName = "string"
          ),
          SourceConnectorProperties = list(
            Marketo = list(
              Object = "string"
            ),
            S3 = list(
              BucketName = "string",
              BucketPrefix = "string"
            ),
            Salesforce = list(
              Object = "string",
              EnableDynamicFieldUpdate = TRUE|FALSE,
              IncludeDeletedRecords = TRUE|FALSE
            ),
            ServiceNow = list(
              Object = "string"
            ),
            Zendesk = list(
              Object = "string"
            )
          )
        ),
        Tasks = list(
          list(
            ConnectorOperator = list(
              Marketo = "PROJECTION"|"LESS_THAN"|"GREATER_THAN"|"BETWEEN"|"ADDITION"|"MULTIPLICATION"|"DIVISION"|"SUBTRACTION"|"MASK_ALL"|"MASK_FIRST_N"|"MASK_LAST_N"|"VALIDATE_NON_NULL"|"VALIDATE_NON_ZERO"|"VALIDATE_NON_NEGATIVE"|"VALIDATE_NUMERIC"|"NO_OP",
              S3 = "PROJECTION"|"LESS_THAN"|"GREATER_THAN"|"BETWEEN"|"LESS_THAN_OR_EQUAL_TO"|"GREATER_THAN_OR_EQUAL_TO"|"EQUAL_TO"|"NOT_EQUAL_TO"|"ADDITION"|"MULTIPLICATION"|"DIVISION"|"SUBTRACTION"|"MASK_ALL"|"MASK_FIRST_N"|"MASK_LAST_N"|"VALIDATE_NON_NULL"|"VALIDATE_NON_ZERO"|"VALIDATE_NON_NEGATIVE"|"VALIDATE_NUMERIC"|"NO_OP",
              Salesforce = "PROJECTION"|"LESS_THAN"|"CONTAINS"|"GREATER_THAN"|"BETWEEN"|"LESS_THAN_OR_EQUAL_TO"|"GREATER_THAN_OR_EQUAL_TO"|"EQUAL_TO"|"NOT_EQUAL_TO"|"ADDITION"|"MULTIPLICATION"|"DIVISION"|"SUBTRACTION"|"MASK_ALL"|"MASK_FIRST_N"|"MASK_LAST_N"|"VALIDATE_NON_NULL"|"VALIDATE_NON_ZERO"|"VALIDATE_NON_NEGATIVE"|"VALIDATE_NUMERIC"|"NO_OP",
              ServiceNow = "PROJECTION"|"CONTAINS"|"LESS_THAN"|"GREATER_THAN"|"BETWEEN"|"LESS_THAN_OR_EQUAL_TO"|"GREATER_THAN_OR_EQUAL_TO"|"EQUAL_TO"|"NOT_EQUAL_TO"|"ADDITION"|"MULTIPLICATION"|"DIVISION"|"SUBTRACTION"|"MASK_ALL"|"MASK_FIRST_N"|"MASK_LAST_N"|"VALIDATE_NON_NULL"|"VALIDATE_NON_ZERO"|"VALIDATE_NON_NEGATIVE"|"VALIDATE_NUMERIC"|"NO_OP",
              Zendesk = "PROJECTION"|"GREATER_THAN"|"ADDITION"|"MULTIPLICATION"|"DIVISION"|"SUBTRACTION"|"MASK_ALL"|"MASK_FIRST_N"|"MASK_LAST_N"|"VALIDATE_NON_NULL"|"VALIDATE_NON_ZERO"|"VALIDATE_NON_NEGATIVE"|"VALIDATE_NUMERIC"|"NO_OP"
            ),
            DestinationField = "string",
            SourceFields = list(
              "string"
            ),
            TaskProperties = list(
              "string"
            ),
            TaskType = "Arithmetic"|"Filter"|"Map"|"Mask"|"Merge"|"Truncate"|"Validate"
          )
        ),
        TriggerConfig = list(
          TriggerType = "Scheduled"|"Event"|"OnDemand",
          TriggerProperties = list(
            Scheduled = list(
              ScheduleExpression = "string",
              DataPullMode = "Incremental"|"Complete",
              ScheduleStartTime = as.POSIXct(
                "2015-01-01"
              ),
              ScheduleEndTime = as.POSIXct(
                "2015-01-01"
              ),
              Timezone = "string",
              ScheduleOffset = 123,
              FirstExecutionFrom = as.POSIXct(
                "2015-01-01"
              )
            )
          )
        )
      ),
      Batches = list(
        list(
          StartTime = as.POSIXct(
            "2015-01-01"
          ),
          EndTime = as.POSIXct(
            "2015-01-01"
          )
        )
      )
    )
  ),
  ObjectTypeName = "string",
  RoleArn = "string",
  Tags = list(
    "string"
  )
)