Lecture à partir des entités Salesforce Marketing Cloud - AWS Glue
Requêtes de partitionnement

Les traductions sont fournies par des outils de traduction automatique. En cas de conflit entre le contenu d'une traduction et celui de la version originale en anglais, la version anglaise prévaudra.

Lecture à partir des entités Salesforce Marketing Cloud

Prérequis

Un objet Salesforce Marketing Cloud à partir duquel vous souhaitez lire. Vous aurez besoin du nom de l’objet, comme Activity ou Campaigns. Le tableau suivant présente les entités prises en charge.

Entités prises en charge pour la source :

Entité utilisateur Peut être filtré Limit prise en charge Order by prise en charge SELECT prise en charge* Partitionnement pris en charge
Event Notification Callback REST Non Non Non Oui Non
Seed-List REST Non Oui Non Oui Non
Configuration REST Oui Oui Non Oui Non
Vérification de domaine REST Oui Oui Oui Oui Non
Objects Nested Tags REST Oui Non Non Oui Non
Contact REST Non Oui Non Oui Non
Event Notification Subscription REST Non Non Non Oui Non
Messagerie REST Non Oui Non Oui Non
Activité SOAP Non Non Non Oui Oui
Bounce Event SOAP Non Non Non Oui Oui
Click Event SOAP Non Non Non Oui Oui
Content Area SOAP Non Non Non Oui Oui
Data Extension SOAP Non Oui Non Oui Oui
E-mails SOAP Non Oui Non Oui Oui
Forwarded Email Event SOAP Non Oui Non Oui Oui
Forward Email OptInEvent SOAP Non Oui Non Oui Oui
Lien SOAP Non Oui Non Oui Oui
Link Send SOAP Non Oui Non Oui Oui
Liste SOAP Non Oui Non Oui Oui
List Subscriber SOAP Non Oui Non Oui Oui
Not Sent Event SOAP Non Oui Non Oui Oui
Open Event SOAP Non Oui Non Oui Oui
Envoyer SOAP Non Oui Non Oui Oui
Sent Event SOAP Non Oui Non Oui Oui
Subscriber SOAP Non Oui Non Oui Oui
Survey Event SOAP Non Oui Non Oui Oui
Unsub Event SOAP Non Oui Non Oui Oui
Audit Events REST Non Oui Oui Oui Non
Campagnes REST Non Oui Oui Oui Non
Interactions REST Non Oui Oui Oui Non
Content Assets REST Non Oui Oui Oui Non

Exemple pour REST :

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

Exemple pour SOAP :

salesforcemarketingcloud_read = glueContext.create_dynamic_frame.from_options(
    connection_type="salesforcemarketingcloud",
    connection_options={
        "connectionName": "connectionName",
        "ENTITY_NAME": "Activity",
        "API_VERSION": "v1",
        "INSTANCE_URL": "https://**********************.soap.marketingcloudapis.com"
    }
)

Détails des entités et des champs Salesforce Marketing Cloud :

Les tableaux ci-après décrivent les entités Salesforce Marketing Cloud. Il existe des entités REST avec des métadonnées statiques et des entités SOAP avec des métadonnées dynamiques.

Entités REST avec métadonnées statiques :

Entité Champ Type de données Opérateurs pris en charge
Event Notification Callback callbackId Chaîne
callbackName Chaîne
url Chaîne
maxBatchSize Entier
status Chaîne
statusReason Chaîne
Seed-List id Chaîne
name Chaîne
description Chaîne
activeSeedCount Entier
Configuration customerKey Chaîne
name Chaîne
description Chaîne
locationType Chaîne '='
awsFileTransferLocation Struct
Domain verification enterpriseId Entier
status Chaîne '='
domainType Chaîne '='
memberId Entier
emailSendTime DateTime
domaine Chaîne
isSendable Booléen
Objects Nested Tags id Entier
modifiedDate DateTime
balises Liste
name Chaîne
description Chaîne
parentId Entier
Contact values Liste
Event Notification Subscription subscriptionName Chaîne
callbackId Chaîne
callbackName Chaîne
eventCategoryTypes Liste
filtres Liste
url Chaîne
maxBatchSize Entier
subscriptionId Chaîne
status Chaîne
statusReason Chaîne
Messagerie deliveryTime DateTime
id Chaîne
messageId Chaîne
status Chaîne
to Struct
Interactions status Chaîne '='
id Chaîne
key Chaîne
name Chaîne
lastPublishedDate DateTime
description Chaîne
version Entier
workflowApiVersion Entier
createdDate DateTime
modifiedDate DateTime
goals Struct
stats Struct
entryMode Chaîne
defaults Struct
executionMode Struct
definitionId Chaîne
Content Assets id Entier
customerKey Chaîne
objectId Chaîne
contentType Chaîne
assetType Struct
name Chaîne
description Chaîne
owner Struct
createdDate DateTime
createdBy Struct
modifiedDate DateTime
modifiedBy Struct
thumbnail Struct
category Struct
meta Struct
vues Struct
availableViews Struct
data Struct
legacyData Struct
modelVersion Entier
Version Entier
Locked (Verrouillée) Booléen
FileProperties Struct
Balises Liste
Contenu Chaîne
Conception Chaîne
SuperContent Chaîne
CustomFields Struct
Blocs Struct
MinBlocks Entier
MaxBlocks Entier
Canaux Struct
AllowedBlocks Liste
Emplacements Struct
BusinessUnitAvailability Struct
sharingProperties Struct
sharingProperties.sharedWith Struct
sharingProperties.sharingType Chaîne
Modèle Struct
Fichier Chaîne
GenerateFrom Chaîne
Audit Events id Entier
createdDate DateTime
memberId Entier
enterpriseId Entier
employee Struct
objectType Struct
fonctionnement Struct
objet Struct
transactionId Chaîne
Campagnes id Entier
createdDate DateTime
modifiedDate DateTime
name Chaîne
description Chaîne
campaignCode Chaîne
color Chaîne
favorite Booléen

Entités SOAP avec métadonnées dynamiques :

Entité Type de données Opérateurs pris en charge
Activité Chaîne LIKE,!=,=
Struct
Entier !=,=,>=,<=,<,>
Double !=,=,>=,<=,<,>
Booléen !=,=
DateTime >=,<=,<,>,=,BETWEEN
Bounce Event Entier !=,=,>=,<=,<,>
DateTime >=,<=,<,>,=,BETWEEN
Chaîne LIKE,!=,=
Struct
Click Event Entier !=,=,>=,<=,<,>
DateTime >=,<=,<,>,=,BETWEEN
Chaîne LIKE,!=,=
Struct
Content Area Struct
Chaîne LIKE,!=,=
Entier !=,=,>=,<=,<,>
DateTime >=,<=,<,>,=,BETWEEN
Booléen !=,=
Data Extension DateTime >=,<=,<,>,=,BETWEEN
Chaîne LIKE,!=,=
E-mails Entier !=,=,>=,<=,<,>
Chaîne LIKE,!=,=
DateTime >=,<=,<,>,=,BETWEEN
Booléen !=,=
Struct
Forwarded Email Event Entier !=,=,>=,<=,<,>
Chaîne LIKE,!=,=
DateTime >=,<=,<,>,=,BETWEEN
Struct
Forwarded Email OptInEvent Entier !=,=,>=,<=,<,>
Chaîne LIKE,!=,=
DateTime >=,<=,<,>,=,BETWEEN
Struct
Lien Entier !=,=,>=,<=,<,>
Link Send Entier !=,=,>=,<=,<,>
Chaîne LIKE,!=,=
Double !=,=,>=,<=,<,>
Liste Entier !=,=,>=,<=,<,>
Chaîne LIKE,!=,=
DateTime >=,<=,<,>,=,BETWEEN
Struct
List Subscriber Entier !=,=,>=,<=,<,>
Chaîne LIKE,!=,=
DateTime >=,<=,<,>,=,BETWEEN
Struct
Not Sent Event Entier !=,=,>=,<=,<,>
Chaîne LIKE,!=,=
DateTime >=,<=,<,>,=,BETWEEN
Struct
Open Event Entier !=,=,>=,<=,<,>
Chaîne LIKE,!=,=
DateTime >=,<=,<,>,=,BETWEEN
Struct
Envoyer Entier !=,=,>=,<=,<,>
Chaîne LIKE,!=,=
DateTime >=,<=,<,>,=,BETWEEN
Booléen !=,=
Struct
Sent Event Entier !=,=,>=,<=,<,>
Chaîne LIKE,!=,=
DateTime >=,<=,<,>,=,BETWEEN
Struct
Subscriber Entier !=,=,>=,<=,<,>
Chaîne LIKE,!=,=
DateTime >=,<=,<,>,=,BETWEEN
Struct
Survey Event Entier !=,=,>=,<=,<,>
Chaîne LIKE,!=,=
DateTime >=,<=,<,>,=,BETWEEN
Struct
Unsub Event Entier !=,=,>=,<=,<,>
Chaîne LIKE,!=,=
DateTime >=,<=,<,>,=,BETWEEN
Booléen !=,=
Struct

Requêtes de partitionnement

Dans Salesforce Marketing Cloud, les champs de type de données Integer et DateTime prennent en charge le partitionnement basé sur les champs.

Vous pouvez indiquer les options Spark supplémentaires PARTITION_FIELD, LOWER_BOUND, UPPER_BOUND et NUM_PARTITIONS si vous souhaitez utiliser la simultanéité dans Spark. Avec ces paramètres, la requête d’origine serait divisée en NUM_PARTITIONS nombres de sous-requêtes pouvant être exécutées simultanément par les tâches Spark.

  • PARTITION_FIELD : le nom du champ à utiliser pour partitionner la requête.

  • LOWER_BOUND : une valeur limite inférieure inclusive du champ de partition choisi.

    Pour le champ Timestamp, nous acceptons le format d’horodatage Spark utilisé dans les requêtes SQL Spark.

    Exemples de valeurs valides :

    “2024-05-07T02:03:00.00Z"

  • UPPER_BOUND : une valeur limite supérieure exclusive du champ de partition choisi.

  • NUM_PARTITIONS : le nombre de partitions.

Exemple :

salesforcemarketingcloud_read = glueContext.create_dynamic_frame.from_options(
    connection_type="salesforcemarketingcloud",
    connection_options={
        "connectionName": "connectionName",
        "ENTITY_NAME": "ListSubscriber",
        "API_VERSION": "v1",
        "PARTITION_FIELD": "CreatedDate",
        "LOWER_BOUND": "2023-09-07T02:03:00.000Z",
        "UPPER_BOUND": "2024-05-07T02:03:00.000Z",
        "NUM_PARTITIONS": "10"
    }
)