Escritura en Salesforce - AWS Glue

Escritura en Salesforce

Requisitos previos

Un objeto de Salesforce en el que le gustaría escribir. Necesitará el nombre del objeto, como Account, Case o Opportunity.

El conector de Salesforce admite cuatro operaciones de escritura:

  • INSERT

  • UPSERT

  • UPDATE

  • DELETE

Al utilizar la operación de escritura UPSERT, debe proporcionar la opción ID_FIELD_NAMES para especificar el campo de ID externo de los registros.

También se pueden agregar opciones de conexión:

  • TRANSFER_MODE: admite dos modos: SYNC y ASYNC. El valor predeterminado es SYNC. Cuando se establece en ASYNC, se utilizará Bulk API 2.0 Ingest para el procesamiento.

  • FAIL_ON_FIRST_ERROR: el valor predeterminado es FALSE, lo que significa que el trabajo de AWS Glue continuará procesando todos los datos incluso si hay algunos registros de escritura con error. Cuando se establece en TRUE, el trabajo de AWS Glue presentará fallas si hay algún registro de escritura con error y no continuará el procesamiento.

Ejemplo

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"
    }
)