View a markdown version of this page

Contoh: Mengintegrasikan Amazon S3 secara terprogram dengan Connect Customer Profiles - Pelanggan Amazon Connect
Langkah 1: Buat file JSONLangkah 2: Panggil PutIntegrationLangkah 3: Hubungi Amazon AppFlow StartFlow

Terjemahan disediakan oleh mesin penerjemah. Jika konten terjemahan yang diberikan bertentangan dengan versi bahasa Inggris aslinya, utamakan versi bahasa Inggris.

Contoh: Mengintegrasikan Amazon S3 secara terprogram dengan Connect Customer Profiles

Dengan menggunakan Customer Profiles PutIntegration API, Anda dapat secara terprogram membuat integrasi untuk S3, Salesforce, Marketo, dan lainnya.

Dalam topik ini kami menunjukkan cara membuat integrasi S3 dengan interval sinkronisasi 15 menit, nilai minimum yang saat ini didukung.

Langkah 1: Buat file JSON

Buat file JSON dengan konten berikut:

{
    "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"}
        ]
    }
}

Untuk menyesuaikan JSON dengan nilai-nilai Anda sendiri, ikuti panduan ini:

  • FlowName: Dapat berupa STRING [a-zA-Z0-9] [\ w! @ #.-] +

  • ScheduleStartTime: Atur ke DateTime + 5 menit saat ini dalam waktu zaman.

  • FirstExecutionFrom: Buka S3, lihat tanggal file, dan gunakan tanggal yang sebelum tanggal tertua.

  • Tasks: DefinisikanTaskType. Di Sourcefields bidang Anda harus menyediakan SEMUA kolom yang Anda miliki di CSV Anda dalam array itu. Kemudian, untuk setiap item dalam array itu, Anda perlu menentukanConnectorOperator. Contoh ini untuk dokumen CSV dengan dua kolom: colA dancolB.

Langkah 2: Panggil PutIntegration API

Setelah Anda membuat dan menyesuaikan file JSON dengan nilai-nilai Anda, panggil PutIntegration API, seperti yang ditunjukkan pada contoh berikut:

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

Respons dari PutIntegration mengembalikan URI aliran. Contoh:

{
    "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": {}
}

Langkah 3: Panggil AppFlow StartFlow API Amazon

Gunakan URI aliran untuk memanggil Amazon AppFlow StartFlow API. Contoh:

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