Inizia a utilizzare l'Apigee Integration e un trigger di Salesforce

Scopri come creare un'integrazione di esempio nell'Apigee Integration utilizzando il trigger di Salesforce. I passaggi seguenti descrivono come configurare il trigger, le attività, i connettori e le mappature dei dati necessari per eseguire un'integrazione completa.

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

Diagramma sequenza di esempio Diagramma sequenza di esempio

Un attivatore Salesforce è iscritto al canale delle opportunità di Salesforce. Le modifiche ai dati dell'opportunità Salesforce richiamano un'Apigee 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 i dati vengono modificati, ma lo stato rimane aperto, l'integrazione invia un messaggio a un argomento Pub/Sub utilizzando un connettore.

I passaggi seguenti descrivono come configurare il trigger, le attività, i profili di autenticazione, i bordi, le variabili e la mappatura dei dati necessari per eseguire un'integrazione corretta.

Prima di iniziare

  • Verifica che nel tuo account sviluppatore Salesforce sia attiva la funzionalità Change Data Capture (CDC). Questo tutorial presuppone che tu disponga di un account sviluppatore Salesforce esistente con la configurazione utente e il set di autorizzazioni richiesti. Per informazioni sull'impostazione degli utenti Salesforce e sul set di autorizzazioni, consulta Configurare un trigger di Salesforce.
  • Assegna i seguenti ruoli IAM all'agente di servizio di integrazione Apigee(service-PROJECT_NUMBER@gcp-sa-apigee.iam.gserviceaccount.com) nel tuo progetto Google Cloud.
    • Editor Pub/Sub
    • Amministratore connettori
    • Invoker dell'integrazione Apigee
    Per saperne di più sull'assegnazione dei ruoli IAM, consulta Ruoli e autorizzazioni IAM.
  • Crea la tabella Cloud SQL per archiviare i dati della CDC di Salesforce.
    1. Nella console Google Cloud, vai alla pagina Istanze Cloud SQL e connettiti all'istanza MySQL. Vedi Connettersi a Cloud SQL per MySQL da Cloud Shell.

      Vai alle istanze Cloud SQL

    2. Crea il seguente database MySQL sulla 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 questo 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. Nell'interfaccia utente di Apigee, seleziona la tua organizzazione Apigee.
  2. Fai clic su Sviluppa > Integrazioni.
  3. Fai clic su Create integration (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 il trigger Salesforce

Per aggiungere e configurare un attivatore Salesforce per l'integrazione, segui questi passaggi:

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

      Viene visualizzata la finestra di dialogo Aggiungi configurazione istanza Salesforce.

      • Nome connessione istanza Salesforce: inserisci un nome di connessione per l'istanza Salesforce. Ad esempio, CDC-PlatformUser.
      • Dominio Salesforce: inserisci il nome del 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 ulteriori 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 dall'elenco a discesa.

      Viene visualizzata la finestra di dialogo Aggiungi canale Salesforce.

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

    Le modifiche alle proprietà vengono salvate automaticamente.

Aggiungi e configura le attività

Questo tutorial utilizza le attività Connettori e Mappatura dati. I dettagli di configurazione per ciascuna di queste attività sono descritti come segue.

Configura un'attività Connettori con una connessione Cloud SQL per MySQL

Completa i seguenti passaggi per configurare un'attività Connettori in modo da inserire i record in una tabella Cloud SQL esistente utilizzando la connessione Cloud SQL per MySQL:

  1. Seleziona + Aggiungi un'attività/un attivatore > Tasks nel designer dell'integrazione per visualizzare l'elenco delle attività disponibili.
  2. Fai clic sull'elemento Connettori e posizionalo nel designer dell'integrazione.
  3. Fai clic sull'elemento dell'attività Connettori nel designer per visualizzare il riquadro di configurazione dell'attività Connettori.
  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 l'attività del connettore.

  6. Esegui le seguenti operazioni nella finestra di dialogo Configura l'attività del connettore:
    1. Seleziona la regione della connessione.
    2. Una volta scelta una regione, viene visualizzata la colonna Connessione. Seleziona la tua connessione Cloud SQL per MySQL dall'elenco delle connessioni disponibili.
    3. Una volta scelta una connessione, viene visualizzata la colonna Tipo. Seleziona Entità, quindi 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à Connettori con una connessione Cloud Pub/Sub

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

  1. Seleziona + Aggiungi un'attività/un attivatore > Tasks nel designer dell'integrazione per visualizzare l'elenco delle attività disponibili.
  2. Fai clic sull'elemento Connettori e posizionalo nel designer dell'integrazione.
  3. Fai clic sull'elemento dell'attività Connettori nel designer per visualizzare il riquadro di configurazione dell'attività Connettori.
  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 l'attività del connettore.

  6. Esegui le seguenti operazioni nella finestra di dialogo Configura l'attività del connettore:
    1. Seleziona la regione della connessione.
    2. Una volta scelta una regione, viene visualizzata la colonna Connessione. Seleziona la tua connessione Pub/Sub dall'elenco di connessioni disponibili.
    3. Una volta scelta una connessione, viene visualizzata la colonna Tipo. Seleziona Actions (Azioni), quindi 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, segui questi passaggi:

  1. Seleziona Aggiungi un'attività/attivatore > Tasks per visualizzare un elenco di attività disponibili.
  2. Fai clic sull'elemento Mappatura dei dati e posizionalo 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 consente di mappare le variabili di input a quelle di output desiderate, utilizzando le funzioni di trasformazione disponibili. L'output è quindi disponibile come variabile per qualsiasi altro trigger o attività di integrazione. Per maggiori dettagli sul passaggio dei dati come variabili, consulta Utilizzare le variabili in Apigee Integration.

  5. Fai clic su + Aggiungi nuova variabile e crea le seguenti variabili di output:
    Nome variabile di output Tipo di dati
    OpportunityIsClosed Boolean
    OpportunityId String
    PubSubMessage String
  6. Crea la seguente mappatura tra la variabile SalesforceTriggerCdcPayload e le variabili Carico di input del connettore come illustrato nella seguente tabella:
    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. Una volta completata la mappatura, chiudi il riquadro. Le modifiche verranno salvate automaticamente.

Aggiungi connessione perimetrale

Un perimetro è una connessione tra due elementi qualsiasi in un'integrazione, mentre una condizione del perimetro consente di specificare le condizioni che devono essere soddisfatte affinché il controllo di un'integrazione passi all'attività connessa dal perimetro. Per ulteriori informazioni sulle condizioni dei bordi, vedi Bordi.

  1. Aggiungi una connessione perimetrale dall'elemento attivatore Salesforce all'elemento Mappatura dei dati.
  2. Aggiungi una connessione perimetrale dall'elemento Data Mapping all'elemento Insert row to Cloud SQL Connector con la seguente condizione perimetrale: 
      $OpportunityIsClosed$ = TRUE
  3. Aggiungi un'altra connessione perimetrale dall'elemento Data Mapping all'elemento Connettore Cloud Pub/Sub con la seguente condizione perimetrale: 
      $OpportunityIsClosed$ = FALSE
Immagine di esempio che mostra le connessioni perimetrali Immagine di esempio che mostra le connessioni perimetrali

Testare l'integrazione

Per testare la nuova integrazione:

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

    Viene visualizzata la finestra di dialogo Testa integrazione.

  2. Fai clic su Test Integration (Verifica l'integrazione).

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

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

Per saperne di più sui test, consulta Testare e pubblicare le integrazioni.

Per verificare il successo 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 fai clic su Visualizza messaggi per confermare la ricezione del messaggio inviato dall'integrazione.
  • Esamina i log di Apigee 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 eseguire un'integrazione. Ogni voce include i dettagli del tentativo di esecuzione, tra cui:
      • Nome integrazione
      • ID esecuzione
      • Stato
      • Ora di inizio
      • Durata
      • Versione 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 delle attività e ai payload variabili.