Consulta i connettori supportati per Application Integration.

Richiama un'integrazione per un evento Change Data Capture (CDC) di Salesforce

Scopri come creare un'integrazione di esempio in Application Integration utilizzando l'trigger Salesforce. I passaggi riportati di seguito descrivono come configurare l'attivatore, le attività, i connettori e le mappature dei dati necessari per eseguire un'integrazione completa.

In questa guida rapida, utilizzerai l'trigger Salesforce per richiamare un'integrazione nell'Application Integration per un evento Change Data Capture (CDC) di Salesforce, come mostrato nella figura seguente:

Diagramma di sequenza di esempio Diagramma di sequenza di esempio

Un trigger Salesforce è iscritto al canale Opportunità Salesforce. Le modifiche ai dati dell'opportunità Salesforce richiamano un'Application Integration che estrae lo stato dell'opportunità Salesforce. Se lo stato è Chiuso, l'integrazione estrae i dettagli dell'opportunità e scrive i dati in un'istanza Cloud SQL utilizzando un connettore. Se si verifica una modifica dei dati, ma lo stato rimane aperto, l'integrazione invia un messaggio a un argomento Pub/Sub utilizzando un connettore.

I passaggi riportati di seguito descrivono come configurare l'attivatore, le attività, i profili di autenticazione, gli edge, le variabili e la mappatura dei dati necessari per eseguire un'integrazione riuscita.

Prima di iniziare

  • Verifica che nel tuo account sviluppatore Salesforce sia attivato il rilevamento dei cambiamenti (CDC). Questo tutorial presuppone che tu abbia già un account sviluppatore Salesforce con le autorizzazioni e la configurazione utente richieste. Per informazioni sulla configurazione degli utenti e sull'insieme di autorizzazioni di Salesforce, vedi Configurare un attivatore Salesforce.
  • Assegna i seguenti ruoli IAM all'agente di servizio di integrazione delle applicazioni(service-PROJECT_NUMBER@gcp-sa-integrations.iam.gserviceaccount.com) nel tuo progetto Google Cloud.
    • Pub/Sub Editor
    • Connectors Admin
    • Application Integration Invoker
    Per ulteriori informazioni sull'assegnazione dei ruoli IAM, consulta Ruoli e autorizzazioni IAM.
  • Crea la tabella Cloud SQL per archiviare i dati CDC di Salesforce.
    1. Nella console Google Cloud, vai alla pagina Istanze Cloud SQL e connettiti all'istanza MySQL. Consulta Connettersi a Cloud SQL per MySQL da Cloud Shell.

      Vai alle istanze Cloud SQL

    2. Crea il seguente database MySQL nella tua istanza Cloud SQL: 
      CREATE DATABASE SALESFORCE_TRIGGER_DEMO;
USE SALESFORCE_TRIGGER_DEMO;

CREATE TABLE OPPORTUNITIES
(
     ID              INT NOT NULL AUTO_INCREMENT,
     NAME            VARCHAR(150) NOT NULL,
     AMOUNT          DOUBLE NOT NULL,
     DT_CLOSE        VARCHAR(150) NOT NULL,
     PRIMARY KEY     (ID)
);
COMMIT;
    3. Verifica che la tabella sia stata creata eseguendo il seguente comando. 
      SELECT * FROM OPPORTUNITIES;
  • Crea una connessione Cloud SQL per MySQL in Connettori. Per informazioni dettagliate, consulta Creare una connessione Cloud SQL per MySQL .
  • Crea una connessione Cloud Pub/Sub in Connettori. Per informazioni dettagliate, consulta Creare una connessione Cloud Pub/Sub .

Creazione di una nuova integrazione

Per creare una nuova integrazione, segui questi passaggi:

  1. Nella console Google Cloud, vai alla pagina Integrazione delle applicazioni.

    Vai ad Application Integration

  2. Nel menu di navigazione, fai clic su Integrations (Integrazioni). Viene visualizzata la pagina Integrazioni.
  3. Fai clic su Crea integrazione.
  4. Inserisci un nome e una descrizione nella finestra di dialogo Crea integrazione. Ad esempio, Demo-CDC-Opportunities.
  5. Seleziona una regione per l'integrazione.
  6. Fai clic su Crea per aprire il designer dell'integrazione.

Aggiungi e configura l'attivatore Salesforce

Per aggiungere e configurare un trigger Salesforce all'integrazione, segui questi passaggi:

  1. Nel designer di integrazione, seleziona Aggiungi un'attività/trigger > Trigger per visualizzare un elenco degli attivatori disponibili.
  2. Fai clic e posiziona l'elemento Trigger Salesforce nel designer di integrazione.
  3. Fai clic sull'elemento Trigger Salesforce nel riquadro per aprire il riquadro di configurazione dell'attivatore.
  4. Configura i seguenti campi in Input trigger:
    • Tipo di evento: seleziona Acquisizione dati sulle modifiche (CDC) dall'elenco a discesa.
    • Configurazione dell'istanza Salesforce: fai clic sull'opzione + Aggiungi nuova configurazione dell'istanza Salesforce nell'elenco a discesa.

      Viene visualizzata la finestra di dialogo Aggiungi configurazione istanza Salesforce.

      • Nome connessione istanza Salesforce: inserisci un nome per la connessione all'istanza Salesforce. Ad esempio, CDC-PlatformUser.
      • Dominio Salesforce: inserisci il nome di dominio Salesforce. Puoi trovare queste informazioni nella pagina Account Salesforce > Visualizza profilo.
      • Profilo di autenticazione: seleziona un profilo di autenticazione. Se non hai un profilo di autenticazione, creane uno nuovo. Per informazioni, vedi Creare un nuovo profilo di autenticazione.
      • Fai clic su Aggiungi.
    • Configurazione del canale Salesforce: fai clic sull'opzione + Aggiungi nuova configurazione del canale Salesforce nell'elenco a discesa.

      Viene visualizzata la finestra di dialogo Aggiungi canale Salesforce.

      • Nome dell'oggetto Salesforce: inserisci Opportunity.
      • Fai clic su Aggiungi.
    • Operazione: seleziona Aggiorna dall'elenco a discesa.

    Le modifiche alle proprietà vengono salvate automaticamente.

Aggiungere e configurare attività

Questo tutorial utilizza le attività Connettori e Mappatura dei dati. I dettagli di configurazione di ciascuna di queste attività sono descritti di seguito.

Configurare un'attività Connectors con una connessione Cloud SQL per MySQL

Per configurare un'attività Connettori per inserire record in una tabella Cloud SQL esistente utilizzando la connessione Cloud SQL per MySQL, svolgi i seguenti passaggi:

  1. Seleziona + Aggiungi un'attività/un trigger > Attività nel designer dell'integrazione per visualizzare l'elenco delle attività disponibili.
  2. Fai clic e posiziona l'elemento Connettori nel designer di integrazione.
  3. Fai clic sull'elemento attività Connettori nel designer per visualizzare il riquadro di configurazione dell'attività Connessioni.
  4. Fai clic su e modifica il nome Connettori in Insert row to Cloud SQL.
  5. Fai clic su Configura attività.

    Viene visualizzata la finestra di dialogo Configura attività del connettore.

  6. Nella finestra di dialogo Configura attività connettore:
    1. Seleziona la regione di connessione.
    2. Una volta scelta una regione, viene visualizzata la colonna Connessione. Seleziona la connessione Cloud SQL per MySQL dall'elenco delle connessioni disponibili.
    3. Una volta scelta una connessione, viene visualizzata la colonna Tipo. Seleziona Entità e poi OPPORTUNITÀ dall'elenco delle entità disponibili.
    4. Una volta scelto un tipo, viene visualizzata la colonna Operazione. Seleziona Crea.
    5. Fai clic su Fine per completare la configurazione della connessione e chiudere il riquadro.

Configurare un'attività Connectors con una connessione Cloud Pub/Sub

Per configurare un'attività Connettori per pubblicare un messaggio Pub/Sub utilizzando la connessione Cloud Pub/Sub, svolgi i seguenti passaggi:

  1. Seleziona + Aggiungi un'attività/un trigger > Attività nel designer dell'integrazione per visualizzare l'elenco delle attività disponibili.
  2. Fai clic e posiziona l'elemento Connettori nel designer di integrazione.
  3. Fai clic sull'elemento attività Connettori nel designer per visualizzare il riquadro di configurazione dell'attività Connessioni.
  4. Fai clic su e modifica il nome Connettori in Publish to cloud pub/sub.
  5. Fai clic su Configura attività.

    Viene visualizzata la finestra di dialogo Configura attività del connettore.

  6. Nella finestra di dialogo Configura attività connettore:
    1. Seleziona la regione di connessione.
    2. Una volta scelta una regione, viene visualizzata la colonna Connessione. Seleziona la connessione Pub/Sub dall'elenco delle connessioni disponibili.
    3. Una volta scelta una connessione, viene visualizzata la colonna Tipo. Seleziona Azioni e poi publishMessage dall'elenco delle azioni disponibili.
    4. Fai clic su Fine per completare la configurazione della connessione e chiudere il riquadro.

Configura l'attività di mappatura dei dati

Per configurare un'attività di mappatura dei dati:

  1. Seleziona Aggiungi un'attività/un trigger > Attività per visualizzare un elenco delle attività disponibili.
  2. Fai clic e posiziona l'elemento Mappatura dei dati nel designer dell'integrazione.
  3. Fai clic sull'elemento Mappatura dei dati nel designer per aprire il riquadro di configurazione dell'attività.
  4. Fai clic su Apri editor di mappatura dei dati.

    L'editor di mappatura dei dati ti consente di mappare le variabili di input alle variabili di output desiderate utilizzando le funzioni di trasformazione disponibili. L'output è quindi disponibile come variabile per qualsiasi altra attività o trigger di integrazione. Per ulteriori dettagli sul passaggio dei dati come variabili, consulta Utilizzare le variabili nell'integrazione delle applicazioni.

  5. Fai clic su + Aggiungi nuova variabile e crea le seguenti variabili di output:
    Nome della variabile di output Tipo di dati
    OpportunityIsClosed Boolean
    OpportunityId String
    PubSubMessage String
  6. Crea la seguente mappatura tra la variabile SalesforceTriggerCdcPayload e le variabili Connector input payload come mostrato nella tabella seguente:
    Input Output
    SalesforceTriggerCdcPayload.GET_PROPERTY("IsClosed").TO_BOOLEAN() OpportunityIsClosed
    SalesforceTriggerCdcPayload.GET_PROPERTY("Id").TO_STRING() OpportunityId
    OpportunityId.TO_DOUBLE() connectorInputPayload.ID(Insert row to Cloud SQL)
    SalesforceTriggerCdcPayload.GET_PROPERTY("Name").TO_STRING() connectorInputPayload.NAME(Insert row to Cloud SQL)
    SalesforceTriggerCdcSnapshot.GET_PROPERTY("Amount").TO_DOUBLE() connectorInputPayload.AMOUNT(Insert row to Cloud SQL)
    SalesforceTriggerCdcSnapshot.GET_PROPERTY("CloseDate").TO_STRING() connectorInputPayload.DT_CLOSE(Insert row to Cloud SQL)
    OpportunityId.CONCAT(" is still open") PubSubMessage
    PubSubMessage connectorInputPayload.message(Publish to cloud pub/sub)

    7. Al termine della mappatura, chiudi il riquadro. Eventuali modifiche verranno salvate automaticamente.

Aggiungi connessione a un dispositivo edge

Un bordo è una connessione tra due elementi in un'integrazione e una condizione di bordo ti consente di specificare le condizioni che devono essere soddisfatte affinché il controllo di un'integrazione venga trasferito all'attività collegata dal bordo. Per ulteriori informazioni sugli spigoli e sulle condizioni degli spigoli, consulta Spigoli.

  1. Aggiungi una connessione di bordo dall'elemento Attivazione Salesforce all'elemento Mappatura dati.
  2. Aggiungi una connessione di bordo dall'elemento Mappatura dei dati all'elemento Inserisci riga nel connettore Cloud SQL con la seguente condizione di bordo: 
      $OpportunityIsClosed$ = TRUE
  3. Aggiungi un'altra connessione di bordo dall'elemento Data Mapping all'elemento Cloud Pub/Sub Connector con la seguente condizione di bordo: 
      $OpportunityIsClosed$ = FALSE
Immagine di esempio che mostra le connessioni dei bordi Immagine di esempio che mostra le connessioni dei bordi

Testa l'integrazione

Per testare la nuova integrazione:

  1. Fai clic su Test nella barra degli strumenti del designer dell'integrazione e poi seleziona l'attivatore Salesforce.

    Viene visualizzata la finestra di dialogo Testa integrazione.

  2. Fai clic su Test integration (Testa l'integrazione).

Testa l'attività Cloud SQL accedendo all'istanza Salesforce e modificando lo stato di un'opportunità in "chiusa".

Testa l'attività Pub/Sub accedendo all'istanza Salesforce e modificando un altro dettaglio dell'opportunità, ma lascia lo stato dell'opportunità su "Aperta".

Per ulteriori informazioni sui test, consulta Testare e pubblicare le integrazioni.

Per verificare l'esito positivo dell'integrazione:

  • Vai alla pagina Cloud SQL.

    Vai a Cloud SQL

    Controlla il database e i log di Cloud SQL per confermare l'inserimento della nuova riga.
  • Vai alla pagina Pub/Sub.

    Vai a Pub/Sub.

    Seleziona l'argomento Pub/Sub e poi fai clic su Visualizza messaggi per confermare la ricezione del messaggio inviato dall'integrazione.
  • Controlla i log di Application Integration per visualizzare lo stato di una determinata integrazione. Per visualizzare i log:
    1. Fai clic su Log nella barra degli strumenti del designer dell'integrazione.
    2. Nella pagina Log di esecuzione, puoi visualizzare i dettagli di ogni tentativo di esecuzione di un'integrazione. Ogni voce include i dettagli del tentativo di esecuzione, tra cui:
      • Nome integrazione
      • ID esecuzione
      • Stato
      • Ora di inizio
      • Durata
      • Versione dell'integrazione
      • ID attivatore
    3. Fai clic sulla freccia di espansione (>) accanto all'integrazione eseguita per visualizzare un elenco espanso di attività e variabili nell'integrazione, insieme allo stato dell'attività e ai payload delle variabili.