Lettura da HubSpot entità - AWS Glue
interrogazioni di partizionamento

Le traduzioni sono generate tramite traduzione automatica. In caso di conflitto tra il contenuto di una traduzione e la versione originale in Inglese, quest'ultima prevarrà.

Lettura da HubSpot entità

Prerequisito

Un HubSpot oggetto da cui desideri leggere. Avrai bisogno del nome dell'oggetto, ad esempio contatto o attività. La seguente tabella mostra le entità supportate.

Entità supportate per l'origine:

Entità APIversione Può essere filtrato Limite Supporta Order by Supporta Select * Supporta il partizionamento
Campagne v1 No Sì No Sì No
Aziende v3 Sì Sì Sì Sì Sì
Contatti v3 Sì Sì Sì Sì Sì
Elenchi di contatti v1 No Sì No Sì No
Offerte v3 Sì Sì Sì Sì Sì
CRMPipeline (Deal Pipelines) v1 No No No Sì No
Eventi e-mail v1 No Sì No Sì No
Calls (Chiamate) v3 Sì Sì Sì Sì Sì
Note v3 Sì Sì Sì Sì Sì
E-mail v3 Sì Sì Sì Sì Sì
Riunioni v3 Sì Sì Sì Sì Sì
Attività v3 Sì Sì Sì Sì Sì
Posta elettronica v3 Sì Sì Sì Sì Sì
Oggetti personalizzati v3 Sì Sì Sì Sì Sì
Moduli v2 No No No Sì No
Owner v3 No Sì No Sì No
Prodotti v3 Sì Sì Sì Sì Sì
ticket v3 Sì Sì Sì Sì Sì
Flussi di lavoro v3 No No No Sì No
Associations v4 Sì No No Sì No
Etichette per associazioni v4 No No No Sì No

Esempio:

hubspot_read = glueContext.create_dynamic_frame.from_options(
    connection_type="hubspot",
    connection_options={
        "connectionName": "connectionName",
        "ENTITY_NAME": "contact",
        "API_VERSION": "v3"
    }

HubSpot dettagli dell'entità e del campo:

HubSpot APIv4:

Entità APIversione Campo Tipo di dati Operatori supportati
Etichetta dell'associazione v4 category Stringa N/A
typeId Numero intero N/D
etichetta Stringa N/A
Associations from Struct N/D
id Stringa "="
in Elenco N/D
Nota

Per l'Associationsoggetto, per recuperare le associazioni tra due oggetti, è necessario fornire il 'from Id' (l'ID del primo oggetto) tramite un filtro obbligatorio durante la creazione di un lavoro. AWS Glue Se in tal caso si desidera recuperare associazioni multiple da, è necessario fornire più IDs associazioni IDs nella clausola. where Ad esempio: Associations per recuperare i contatti IDs «1» e «151», è necessario fornire un filtro come. where id=1 AND id=151

HubSpot APIv3:

Entità Campo Tipo di dati Operatori supportati
Owner firstName Stringa N/A
lastName Stringa N/A
createdAt DateTime N/D
archived Booleano N/D
squadre Elenco N/D
id Stringa N/A
userId Numero intero N/D
e-mail Stringa N/A
updatedAt DateTime N/D
Flusso di lavoro nome Stringa N/A
id Numero intero N/D
tipo Stringa N/A
enabled Booleano N/D
insertedAt Long N/D
updatedAt Long N/D
contactListIds Struct N/D
personaTagIds Elenco N/D

Per le seguenti entità, HubSpot fornisce endpoint per recuperare i metadati in modo dinamico, in modo che il supporto dell'operatore venga acquisito a livello di tipo di dati per ciascuna entità.

Nota

DML_STATUSè un campo virtuale aggiunto a ogni record in fase di esecuzione per determinarne lo stato (/). CREATED UPDATED

Entità Tipo di dati Operatori supportati
Contatti Numero intero "=, !=, <, >, >=, <="
Long "=, !=, <, >, >=, <="
Stringa "=, !=, LIKE"
Data N/D
DateTime «
Booleano "="
Elenco N/D
Struct N/D
Azienda Numero intero "=, !=, <, >, >=, <="
Long "=, !=, <, >, >=, <="
Stringa "=, !=, LIKE"
Data N/D
DateTime «
Booleano "="
Elenco N/D
Struct N/D
Affare Numero intero "=, !=, <, >, >=, <="
Long "=, !=, <, >, >=, <="
Stringa "=, !=, LIKE"
Data N/D
DateTime «
Booleano "="
Elenco N/D
Struct N/D
ticket Numero intero "=, !=, <, >, >=, <="
Long "=, !=, <, >, >=, <="
Stringa "=, !=, LIKE"
Data N/D
DateTime «
Booleano "="
Elenco N/D
Struct N/D
Product Numero intero "=, !=, <, >, >=, <="
Long "=, !=, <, >, >=, <="
Stringa "=, !=, LIKE"
Data N/D
DateTime «
Booleano "="
Elenco N/D
Struct N/D
Oggetto personalizzato Numero intero "=, !=, <, >, >=, <="
Long "=, !=, <, >, >=, <="
Stringa "=, !=, LIKE"
Data N/D
DateTime «
Booleano "="
Elenco N/D
Struct N/D
Esegui una chiamata a Numero intero "=, !=, <, >, >=, <="
Long "=, !=, <, >, >=, <="
Stringa "=, !=, LIKE"
Data N/D
DateTime «
Booleano "="
Elenco N/D
Struct N/D
E-mail Numero intero "=, !=, <, >, >=, <="
Long "=, !=, <, >, >=, <="
Stringa "=, !=, LIKE"
Data N/D
DateTime «
Booleano "="
Elenco N/D
Struct N/D
Riunione Numero intero "=, !=, <, >, >=, <="
Long "=, !=, <, >, >=, <="
Stringa "=, !=, LIKE"
Data N/D
DateTime «
Booleano "="
Elenco N/D
Struct N/D
Nota Numero intero "=, !=, <, >, >=, <="
Long "=, !=, <, >, >=, <="
Stringa "=, !=, LIKE"
Data N/D
DateTime «
Booleano "="
Elenco N/D
Struct N/D
Attività Numero intero "=, !=, <, >, >=, <="
Long "=, !=, <, >, >=, <="
Stringa "=, !=, LIKE"
Data N/D
DateTime «
Booleano "="
Elenco N/D
Struct N/D
Posta elettronica Numero intero "=, !=, <, >, >=, <="
Long "=, !=, <, >, >=, <="
Stringa "=, !=, LIKE"
Data N/D
DateTime «
Booleano "="
Elenco N/D
Struct N/D

HubSpot APIv2:

Entità Campo Tipo di dati Operatori supportati
Modulo portalId Numero intero N/D
guid Stringa N/A
nome Stringa N/A
metodo Stringa N/A
cssClass Stringa N/A
reindirizzare Stringa N/A
submitText Stringa N/A
notifyRecipients Stringa N/A
createdAt Long N/D
updatedAt Long N/D
ignoreCurrentValues Booleano N/D
eliminabile Booleano N/D
inlineMessage Booleano N/D
captchaEnabled Booleano N/D
clonabile Booleano N/D
formFieldGroups Elenco N/D
editable Booleano N/D
deletedAt Numero intero N/D
themeName Stringa N/A
parentId Numero intero N/D
stile Stringa N/A
isPublished Booleano N/D
publishAt Numero intero N/D
unpublishAt Numero intero N/D
publishedAt Numero intero N/D
kickbackEmailWorkflowId Stringa N/A
kickbackEmailsJson Numero intero N/D
customUid Stringa N/A
createMarketableContact Booleano N/D
editVersion Numero intero N/D
thankYouMessageJson Stringa N/A
themeColor Stringa N/A
alwaysCreateNewCompany Booleano N/D
internalUpdatedAt Long N/D
businessUnitId Numero intero N/D
portableKey Stringa N/A
paymentSessionTemplateID Elenco N/D
selectedExternalOptions Elenco N/D

HubSpot APIv1:

Entità Campo Tipo di dati Operatori supportati
Campagna id Numero intero N/D
appId Numero intero N/D
appName Stringa N/A
lastUpdatedTime Long N/D
Elenco contatti dynamic Booleano N/D
nome Stringa N/A
portalId Numero intero N/D
createdAt Long N/D
listId Numero intero N/D
updatedAt Long N/D
ListType Stringa N/A
filtri Elenco N/D
authorId Numero intero N/D
metaData Struct N/D
archived Booleano N/D
ilsFilterBranch Stringa N/A
filterIds Elenco N/D
limitExempt Booleano N/D
interno Booleano N/D
readOnly Booleano N/D
parentId Numero intero N/D
Email_Event id Stringa N/A
tipo Stringa N/A
recipient Stringa N/A
portalId Numero intero N/D
appId Numero intero N/D
appName Stringa N/A
emailCampaignId Long N/D
tentativo Numero intero N/D
creato Long N/D
sentBy Struct N/D
smtpId Stringa N/A
response Stringa N/A
subject Stringa N/A
cc Elenco N/D
bcc Elenco N/D
replyTo Elenco N/D
from Stringa N/A
dropReason Stringa N/A
dropMessage Stringa N/A
browser Struct N/D
userAgent Stringa N/A
durata Long N/D
posizione Struct N/D
filteredEvent Booleano N/D
deviceType Stringa N/A
suppressedReason Stringa N/A
suppressedMessage Stringa N/A
CRM_Pipeline pipelineId Stringa N/A
createdAt Long N/D
updatedAt Long N/D
objectType Stringa N/A
etichetta Stringa N/A
displayOrder Numero intero N/D
attiva Booleano N/D
inscenare Elenco N/D
objectTypeId Stringa N/A
default Booleano N/D

interrogazioni di partizionamento

Puoi fornire le opzioni Spark aggiuntive ePARTITION_FIELD, NUM_PARTITIONS se desideri LOWER_BOUNDUPPER_BOUND, utilizzare la concorrenza in Spark. Con questi parametri, la query originale verrebbe suddivisa in un NUM_PARTITIONS numero di sottoquery che possono essere eseguite contemporaneamente dalle attività Spark.

  • PARTITION_FIELD: il nome del campo da utilizzare per partizionare la query.

  • LOWER_BOUND: un valore limite inferiore inclusivo del campo di partizione scelto.

    Per il DateTime campo, accettiamo il valore in ISO formato.

    Esempi di valori validi:

    “2024-01-01T10:00:00.115Z"

  • UPPER_BOUND: un valore limite superiore esclusivo del campo di partizione scelto.

  • NUM_PARTITIONS: il numero di partizioni.

Nella seguente tabella sono descritti i dettagli del supporto per il partizionamento delle entità:

Nome dell'entità Campi di partizionamento Tipo di dati
contact hs_object_id Long
data di creazione, ultima data di modifica DateTime
company hs_object_id Long
data di creazione, hs_lastmodifieddate DateTime
contratto hs_object_id Long
createdate, hs_createdate, hs_lastmodifieddate DateTime
ticket hs_object_id Long
data di creazione, hs_lastmodifieddate DateTime
prodotto hs_object_id Long
data di creazione, hs_lastmodifieddate DateTime
oggetto_personalizzato hs_object_id Long
data di creazione, hs_lastmodifieddate DateTime
call hs_object_id Long
data di creazione, hs_lastmodifieddate DateTime
e-mail hs_object_id Long
data di creazione, hs_lastmodifieddate DateTime
riunione hs_object_id Long
data di creazione, hs_lastmodifieddate DateTime
note hs_object_id Long
data di creazione, hs_lastmodifieddate DateTime
task hs_object_id Long
data di creazione, hs_lastmodifieddate DateTime
posta_postale hs_object_id Long
data di creazione, hs_lastmodifieddate DateTime

Esempio:

hubspot_read = glueContext.create_dynamic_frame.from_options(
    connection_type="hubspot",
    connection_options={
        "connectionName": "connectionName",
        "ENTITY_NAME": "company",
        "API_VERSION": "v3",
        "PARTITION_FIELD": "hs_object_id"
        "LOWER_BOUND": "50"
        "UPPER_BOUND": "16726619290"
        "NUM_PARTITIONS": "10"
    }