Écriture vers Salesforce - AWS Glue

Écriture vers Salesforce

Prérequis

Un objet Salesforce auquel vous souhaitez écrire. Vous aurez besoin du nom de l’objet, comme Account, Case ou Opportunity.

Le connecteur Salesforce prend en charge quatre opérations d’écriture :

  • INSERT

  • UPSERT

  • UPDATE

  • DELETE

Lorsque vous utilisez l’opération d’écriture UPSERT, vous devez proposer l’option ID_FIELD_NAMES afin de spécifier le champ d’ID externe pour les enregistrements.

Vous pouvez également ajouter d’autres options de connexion :

  • TRANSFER_MODE : prend en charge deux modes : SYNC et ASYNC. La valeur par défaut est SYNC. Lorsque cette option est définie sur ASYNC, Bulk API 2.0 Ingest sera utilisé pour le traitement.

  • FAIL_ON_FIRST_ERROR : la valeur par défaut est FALSE, ce qui signifie que la tâche AWS Glue continuera à traiter toutes les données, même si certains enregistrements d’écriture ont échoué. Lorsqu’elle est définie sur TRUE, la tâche AWS Glue échouera en cas d’échec d’enregistrements d’écriture et le traitement sera interrompu.

Exemple

salesforce_write = glueContext.write_dynamic_frame.from_options(
    frame=frameToWrite,
    connection_type="salesforce",
    connection_options={
        "connectionName": "connectionName",
        "ENTITY_NAME": "Account",
        "API_VERSION": "v60.0",
        "WRITE_OPERATION": "INSERT",
        "TRANSFER_MODE": "ASYNC",
        "FAIL_ON_FIRST_ERROR": "true"
    }
)