寫入到 Salesforce Marketing Cloud 實體 - AWS Glue

寫入到 Salesforce Marketing Cloud 實體

先決條件

  • 您想要寫入到的 Salesforce Marketing 物件。需要指定物件的名稱，例如 List、Campaigns 或下表中列出的任何其他實體。

  • Salesforce Marketing Cloud 連接器支援三種寫入操作：

    • INSERT

    • UPSERT (更新插入)

    • UPDATE

    使用 UPDATE 和 UPSERT 寫入操作時，必須提供 ID_FIELD_NAMES 選項，以指定記錄的外部 ID 欄位。

目的地支援的實體：

實體 優先順序 介面 (REST、SOAP 等） 可以插入 可以更新 可以更新插入
行銷活動 P0 REST Y- 單一 Y- 單一 N
內容資產 P0 REST Y- 單一、大量 Y- 單一 N
聯絡 P1 REST Y- 單一 Y- 單一 N
網域驗證 P1 REST Y- 單一 Y- 單一、大量 N
事件通知回呼 P1 REST Y- 單一 Y- 單一 N
事件通知訂閱 P1 REST Y- 單一 Y- 單一 N
簡訊 P1 REST Y- 單一 N N
物件巢狀標籤 P2 REST Y- 單一 Y- 單一 N
Seed-List P1 REST Y- 單一 Y- 單一 N
設定 P1 REST Y- 單一 Y- 單一 N
Data Extension P0 SOAP Y- 單一 Y- 單一 Y- 單一
電子郵件 P0 SOAP Y- 單一 Y- 單一 N
清單 P0 SOAP Y- 單一 Y- 單一 N
傳送 P0 SOAP Y- 單一 N N
Subscriber P0 SOAP Y- 單一 Y- 單一 N

REST 的 INSERT 操作範例：

salesforcemarketingcloud_write = glueContext.write_dynamic_frame.from_options(
    connection_type="salesforcemarketingcloud",
    connection_options={
        "connectionName": "connectionName",
        "ENTITY_NAME": "Campaigns",
        "API_VERSION": "v1",
        "writeOperation" : "INSERT",
        "INSTANCE_URL": "https://**********************.rest.marketingcloudapis.com"
    }
)

SOAP 的 INSERT 操作範例：

salesforcemarketingcloud_write = glueContext.write_dynamic_frame.from_options(
    connection_type="salesforcemarketingcloud",
    connection_options={
        "connectionName": "connectionName",
        "ENTITY_NAME": "List",
        "API_VERSION": "v1",
        "writeOperation" : "INSERT",
        "INSTANCE_URL": "https://**********************.rest.marketingcloudapis.com"
    }
)

REST 的 UPDATE 操作範例：

salesforcemarketingcloud_write = glueContext.write_dynamic_frame.from_options(
    connection_type="salesforcemarketingcloud",
    connection_options={
        "connectionName": "connectionName",
        "ENTITY_NAME": "Campaigns",
        "API_VERSION": "v1",
        "writeOperation" : "UPDATE",
         "ID_FIELD_NAMES": "id",
        "INSTANCE_URL": "https://**********************.rest.marketingcloudapis.com"
    }
)

SOAP 的 UPDATE 操作範例：

salesforcemarketingcloud_write = glueContext.write_dynamic_frame.from_options(
    connection_type="salesforcemarketingcloud",
    connection_options={
        "connectionName": "connectionName",
        "ENTITY_NAME": "List",
        "API_VERSION": "v1",
        "writeOperation" : "UPDATE",
         "ID_FIELD_NAMES": "id",
        "INSTANCE_URL": "https://**********************.rest.marketingcloudapis.com"
    }
)

SOAP 的 UPSERT 操作範例：

salesforcemarketingcloud_write = glueContext.write_dynamic_frame.from_options(
    connection_type="salesforcemarketingcloud",
    connection_options={
        "connectionName": "connectionName",
        "ENTITY_NAME": "DataExtension/Insert-***E/6*******3",
        "API_VERSION": "v1",
        "writeOperation" : "UPSERT",
        "INSTANCE_URL": "https://**********************.rest.marketingcloudapis.com"
    }
)