View a markdown version of this page

Ejemplo: integre Amazon S3 de forma programática con los perfiles de clientes de Connect Customer - Amazon Connect Customer
Paso 1: crear un archivo JSONPaso 2: Llama PutIntegrationPaso 3: Llama a Amazon AppFlow StartFlow

Las traducciones son generadas a través de traducción automática. En caso de conflicto entre la traducción y la version original de inglés, prevalecerá la version en inglés.

Ejemplo: integre Amazon S3 de forma programática con los perfiles de clientes de Connect Customer

Con la PutIntegration API de perfiles de clientes, puede crear integraciones mediante programación para S3, Salesforce, Marketo y más.

En este tema mostramos cómo crear una integración de S3 con un intervalo de sincronización de 15 minutos, el valor mínimo admitido actualmente.

Paso 1: crear un archivo JSON

Cree un archivo JSON con el siguiente contenido:

{
    "DomainName": "your-domain",
    "ObjectTypeName": "your-object-name", 
    "FlowDefinition": {
        "FlowName": "your-flow-name",
        "KmsArn": "the key ARN is the same as your domain's key",
        "Description": "Created by Customer Profiles",
        "TriggerConfig": {
            "TriggerType": "Scheduled",
            "TriggerProperties": {
                "Scheduled": {
                    "ScheduleExpression": "rate(15minutes)",
                    "DataPullMode": "Incremental",
                    "ScheduleStartTime": 1634244800.435,
                    "FirstExecutionFrom": 1594166400
                }
            }
        },
        "SourceFlowConfig": {
            "ConnectorType":"S3",
            "SourceConnectorProperties": {
                "S3": {
                    "BucketName": "your-bucket",
                    "BucketPrefix": "your-prefix"
                }
            }
        },
        "Tasks": [
            {"TaskType":"Filter","SourceFields":["colA","colB"],"ConnectorOperator":{"S3":"PROJECTION"}},
            {"ConnectorOperator":{"S3":"NO_OP"},"DestinationField":"colA","TaskProperties":{},"SourceFields":["colA"],"TaskType":"Map"},
            {"ConnectorOperator":{"S3":"NO_OP"},"DestinationField":"colB","TaskProperties":{},"SourceFields":["colB"],"TaskType":"Map"}
        ]
    }
}

Para personalizar el código JSON con sus propios valores, siga estas indicaciones:

  • FlowName: Puede ser STRING [a-z] [\ w! A-Z0-9 @#.-] +

  • ScheduleStartTime: establézcalo a DateTime + 5 minutos en tiempo Unix.

  • FirstExecutionFrom: vaya a S3, consulte la fecha del archivo y utilice una fecha anterior a la más antigua.

  • Tasks: defina TaskType. En el campo Sourcefields, debe proporcionar TODAS las columnas que tiene en su CSV en esa matriz. A continuación, para cada uno de los elementos de esa matriz, debe especificar el ConnectorOperator. Este ejemplo corresponde a un documento CSV con dos columnas: colA y colB.

Paso 2: Llama a la API PutIntegration

Una vez que hayas creado y personalizado el archivo JSON con tus valores, llama a la PutIntegration API, como se muestra en el siguiente ejemplo:

aws customer-profiles put-integration --cli-input-json file:///put_integration_s3_cli.json --region us-west-2

La respuesta de PutIntegration devuelve un URI de flujo. Por ejemplo:

{
    "DomainName": "testDomain",
    "Uri": "arn:aws:appflow:us-west-2:9999999999999:flow/Customer_Profiles_testDomain_S3_Salesforce-Account_1634244122247",
    "ObjectTypeName": "your objec type",
    "CreatedAt": "2021-10-14T13:51:57.748000-07:00",
    "LastUpdatedAt": "2021-10-14T13:51:57.748000-07:00",
    "Tags": {}
}

Paso 3: Llama a la AppFlow StartFlow API de Amazon

Usa el URI del flujo para llamar a la AppFlow StartFlow API de Amazon. Por ejemplo:

aws appflow start-flow —flow-name uri --region us-west-2