Weitere Informationen finden Sie unter Unterstützte Connectors für Application Integration.

Integration für ein Salesforce Change Data Capture-Ereignis (CDC) aufrufen

Informationen zum Erstellen einer Beispielintegration in der Anwendungsintegration mit dem Salesforce-Trigger In den folgenden Schritten wird beschrieben, wie Sie den Trigger, Aufgaben, Connectors und Datenabgleiche konfigurieren, die für die Ausführung einer vollständigen Integration erforderlich sind.

In dieser Kurzanleitung verwenden Sie den Salesforce-Trigger, um eine Integration in Application Integration für ein Salesforce Change Data Capture-Ereignis (CDC) aufzurufen, wie in der folgenden Abbildung dargestellt:

Grafik: Beispiel für ein Sequenzdiagramm Grafik: Beispiel für ein Sequenzdiagramm

Ein Salesforce-Trigger hat den Salesforce-Opportunity-Kanal abonniert. Durch Datenänderungen an der Salesforce-Opportunity wird eine Application Integration aufgerufen, die den Status der Salesforce-Opportunity extrahiert. Wenn der Status geschlossen ist, extrahiert die Integration die Opportunity-Details und schreibt die Daten mithilfe eines Connectors in eine Cloud SQL-Instanz. Wenn es eine Datenänderung gibt, der Status jedoch offen bleibt, sendet die Integration mithilfe eines Connectors eine Nachricht an ein Pub/Sub-Thema.

In den folgenden Schritten wird beschrieben, wie Sie Trigger, Aufgaben, Authentifizierungsprofile, Edges, Variablen und die Datenabgleiche konfigurieren, die für eine erfolgreiche Integration erforderlich sind.

Vorbereitung

  • Prüfen Sie, ob für Ihr Salesforce-Entwicklerkonto die Option „Change Data Capture (CDC)“ aktiviert ist. In dieser Anleitung wird davon ausgegangen, dass Sie ein bestehendes Salesforce-Entwicklerkonto mit den erforderlichen Nutzereinstellungen und Berechtigungen haben. Informationen zur Einrichtung von Salesforce-Nutzern und dem Berechtigungsset finden Sie unter Salesforce-Trigger konfigurieren.
  • Weisen Sie dem Dienst-Agent für Application Integration (service-PROJECT_NUMBER@gcp-sa-integrations.iam.gserviceaccount.com) in Ihrem Google Cloud-Projekt die folgenden IAM-Rollen zu.
    • Pub/Sub-Bearbeiter
    • Connectors-Administrator
    • Aufrufer von Anwendungsintegrationen
    Weitere Informationen zum Zuweisen von IAM-Rollen finden Sie unter IAM-Rollen und -Berechtigungen.
  • Erstellen Sie die Tabelle Cloud SQL, um die Salesforce CDC-Daten zu speichern.
    1. Rufen Sie in der Google Cloud Console die Seite Cloud SQL-Instanzen auf und stellen Sie eine Verbindung zu Ihrer MySQL-Instanz her. Verbindung zu Cloud SQL for MySQL mit Cloud Shell herstellen.

      Cloud SQL-Instanzen aufrufen

    2. Erstellen Sie die folgende MySQL-Datenbank auf Ihrer Cloud SQL-Instanz: 
      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. Überprüfen Sie mit dem folgenden Befehl, ob die Tabelle erstellt wurde. 
      SELECT * FROM OPPORTUNITIES;
  • Erstellen Sie eine Cloud SQL for MySQL-Verbindung in Connectors. Ausführliche Informationen finden Sie unter Cloud SQL for MySQL-Verbindung erstellen.
  • Erstellen Sie eine Cloud Pub/Sub-Verbindung in Connectors. Ausführliche Informationen finden Sie unter Cloud Pub/Sub-Verbindung erstellen.

Neue Integration erstellen

So erstellen Sie eine neue Integration:

  1. Rufen Sie in der Google Cloud Console die Seite Application Integration auf.

    Zu Application Integration

  2. Klicken Sie im Navigationsmenü auf Integrationen. Die Seite Integrationen wird angezeigt.
  3. Klicken Sie auf Integration erstellen.
  4. Geben Sie im Dialogfeld Integration erstellen einen Namen und eine Beschreibung ein. Beispiel: Demo-CDC-Opportunities.
  5. Wählen Sie eine Region für die Integration aus.
  6. Klicken Sie auf Erstellen, um den Integrationsdesigner zu öffnen.

Salesforce-Trigger hinzufügen und konfigurieren

Gehen Sie so vor, um einen Salesforce-Trigger hinzuzufügen und zu konfigurieren:

  1. Wählen Sie im Integrationsdesigner Aufgabe/Trigger hinzufügen > Trigger aus, um eine Liste der verfügbaren Trigger aufzurufen.
  2. Klicken Sie auf das Element Salesforce-Trigger und platzieren Sie es im Integrationsdesigner.
  3. Klicken Sie auf das Element Salesforce-Trigger im Canvas, um den Konfigurationsbereich des Triggers zu öffnen.
  4. Konfigurieren Sie die folgenden Felder unter Triggereingabe:
    • Ereignistyp: Wählen Sie Change Data Capture (CDC) aus der Drop-down-Liste aus.
    • Salesforce-Instanzkonfiguration: Klicken Sie auf die Option + Neue Salesforce-Instanzkonfiguration hinzufügen aus der Drop-down-Liste.

      Das Dialogfeld Salesforce-Instanzkonfiguration hinzufügen wird angezeigt.

      • Verbindungsname der Salesforce-Instanz: Geben Sie einen Verbindungsnamen für die Salesforce-Instanz ein. Beispiel: CDC-PlatformUser.
      • Salesforce-Domain: Geben Sie Ihren Salesforce-Domainnamen ein. Diese Informationen finden Sie auf der Seite Salesforce-Konto > Profil anzeigen.
      • Authentifizierungsprofil: Wählen Sie ein Authentifizierungsprofil aus. Falls Sie noch kein Authentifizierungsprofil haben, erstellen Sie ein neues Profil. Weitere Informationen finden Sie unter Neues Authentifizierungsprofil erstellen.
      • Klicken Sie auf Hinzufügen.
    • Salesforce-Kanalkonfiguration: Klicken Sie auf die Option + Neue Salesforce-Kanalkonfiguration hinzufügen aus der Drop-down-Liste.

      Das Dialogfeld Salesforce-Kanal hinzufügen wird angezeigt.

      • Salesforce-Objektname: Geben Sie Opportunity ein.
      • Klicken Sie auf Hinzufügen.
    • Vorgang: Wählen Sie aus der Drop-down-Liste Aktualisieren aus.

    Änderungen an den Attributen werden automatisch gespeichert.

Aufgaben hinzufügen und konfigurieren

In dieser Anleitung werden die Aufgaben Connectors und Datenabgleich verwendet. Konfigurationsdetails für jede dieser Aufgaben werden im Folgenden beschrieben.

Connectors-Aufgabe mit einer Cloud SQL for MySQL-Verbindung konfigurieren

Führen Sie die folgenden Schritte aus, um eine Connectors-Aufgabe zu konfigurieren, um Datensätze mithilfe der Cloud SQL for MySQL-Verbindung in eine vorhandene Cloud SQL-Tabelle einzufügen:

  1. Wählen Sie im Integrationsdesigner + Aufgabe/Trigger hinzufügen > Aufgaben aus, um die Liste der verfügbaren Aufgaben aufzurufen.
  2. Klicken Sie auf das Element Connectors und platzieren Sie es im Integrationsdesigner.
  3. Klicken Sie auf das Connectors-Aufgabenelement im Designer, um den Konfigurationsbereich der Connectors-Aufgabe aufzurufen.
  4. Klicken Sie auf und ändern Sie den Connectors-Namen in Insert row to Cloud SQL.
  5. Klicken Sie auf Aufgabe konfigurieren.

    Das Dialogfeld Connectors-Aufgabe konfigurieren wird angezeigt.

  6. Führen Sie im Dialogfeld Connectors-Aufgabe konfigurieren die folgenden Schritte aus:
    1. Wählen Sie die Verbindungsregion aus.
    2. Nachdem eine Region ausgewählt wurde, wird die Spalte Verbindung angezeigt. Wählen Sie Ihre Cloud SQL for MySQL-Verbindung aus der Liste der verfügbaren Verbindungen aus.
    3. Wenn eine Verbindung ausgewählt ist, wird die Spalte Typ angezeigt. Wählen Sie Entitäten und dann Geschäftschancen aus der Liste der verfügbaren Entitäten aus.
    4. Sobald ein Typ ausgewählt ist, wird die Spalte Vorgang angezeigt. Wählen Sie Erstellen aus.
    5. Klicken Sie auf Fertig, um die Verbindungskonfiguration abzuschließen und den Bereich zu schließen.

Connectors-Aufgabe mit einer Cloud Pub/Sub-Verbindung konfigurieren

So konfigurieren Sie eine Connectors-Aufgabe, um eine Pub/Sub-Nachricht über die Cloud Pub/Sub-Verbindung zu veröffentlichen:

  1. Wählen Sie im Integrationsdesigner + Aufgabe/Trigger hinzufügen > Aufgaben aus, um die Liste der verfügbaren Aufgaben aufzurufen.
  2. Klicken Sie auf das Element Connectors und platzieren Sie es im Integrationsdesigner.
  3. Klicken Sie auf das Connectors-Aufgabenelement im Designer, um den Konfigurationsbereich der Connectors-Aufgabe aufzurufen.
  4. Klicken Sie auf und ändern Sie den Connectors-Namen in Publish to cloud pub/sub.
  5. Klicken Sie auf Aufgabe konfigurieren.

    Das Dialogfeld Connectors-Aufgabe konfigurieren wird angezeigt.

  6. Führen Sie im Dialogfeld Connectors-Aufgabe konfigurieren die folgenden Schritte aus:
    1. Wählen Sie die Verbindungsregion aus.
    2. Nachdem eine Region ausgewählt wurde, wird die Spalte Verbindung angezeigt. Wählen Sie Ihre Pub/Sub-Verbindung aus der Liste der verfügbaren Verbindungen aus.
    3. Wenn eine Verbindung ausgewählt ist, wird die Spalte Typ angezeigt. Wählen Sie Aktionen und dann publishMessage aus der Liste der verfügbaren Aktionen aus.
    4. Klicken Sie auf Fertig, um die Verbindungskonfiguration abzuschließen und den Bereich zu schließen.

Aufgabe "Datenabgleich" konfigurieren

So konfigurieren Sie eine Datenabgleich-Aufgabe:

  1. Wählen Sie Aufgabe/Trigger hinzufügen > Aufgaben aus, um eine Liste der verfügbaren Aufgaben aufzurufen.
  2. Klicken Sie auf das Element Datenabgleich im Integrationsdesigner.
  3. Klicken Sie auf das Element Datenabgleich im Designer, um den Konfigurationsbereich der Aufgabe zu öffnen.
  4. Klicken Sie auf Datenabgleichs-Editor öffnen.

    Mit den Transformationsfunktionen im Datenabgleichs-Editor können Sie Eingabevariablen den gewünschten Ausgabevariablen zuordnen. Die Ausgabe ist dann als Variable für alle anderen Integrationsaufgaben oder Trigger verfügbar. Weitere Informationen zur Übergabe von Daten als Variablen finden Sie unter Variablen in Application Integration verwenden.

  5. Klicken Sie auf + Neue Variable hinzufügen und erstellen Sie die folgenden Ausgabevariablen:
    Ausgabe-Variablenname Datentyp
    OpportunityIsClosed Boolean
    OpportunityId String
    PubSubMessage String
  6. Erstellen Sie die folgende Zuordnung zwischen der Variable SalesforceTriggerCdcPayload und den Variablen der Connectors-Eingabenutzlast, wie in der folgenden Tabelle dargestellt:
    Eingabe Ausgabe
    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. Schließen Sie das Fenster, wenn die Zuordnung abgeschlossen ist. Alle Änderungen werden automatisch gespeichert.

Edge-Verbindung hinzufügen

Ein Edge ist eine Verbindung zwischen zwei Elementen in einer Integration und einer Edge-Bedingung, mit der Sie die Bedingungen angeben können, die erfüllt sein müssen, damit eine Integration an die durch die Edge verbundene Aufgabe übergeben wird. Weitere Informationen zu Edges und Edge-Bedingungen finden Sie unter Edges.

  1. Fügen Sie dem Element Datenabgleich eine Edge-Verbindung aus dem Element Salesforce-Trigger hinzu.
  2. Fügen Sie eine Edge-Verbindung aus dem Element Datenabgleich zum Element Zeile in Cloud SQL Connector einfügen mit der folgenden Edge-Bedingung hinzu: 
      $OpportunityIsClosed$ = TRUE
  3. Fügen Sie dem Element Cloud Pub/Sub Connector eine weitere Edge-Verbindung aus dem Element Datenabgleich mit der folgenden Edge-Bedingung hinzu: 
      $OpportunityIsClosed$ = FALSE
Grafik: Beispielbild mit Edge-Verbindungen Grafik: Beispielbild mit Edge-Verbindungen

Integration testen

So testen Sie die neue Integration:

  1. Klicken Sie in der Symbolleiste des Integrationsdesigners auf Testen und wählen Sie dann den Salesforce-Trigger aus.

    Das Dialogfeld Integration testen wird angezeigt.

  2. Klicken Sie auf Integration testen.

Die Cloud SQL-Aufgabe testen. Melden Sie sich dazu in der Salesforce-Instanz an und ändern Sie den Status einer Opportunity in "Geschlossen".

Testen Sie die Pub/Sub-Aufgabe. Melden Sie sich dazu in der Salesforce-Instanz an und ändern Sie ein anderes Detail der Opportunity, aber behalten Sie den Status der Opportunity als "Offen".

Weitere Informationen zu Tests finden Sie unter Integrationen testen und veröffentlichen.

So überprüfen Sie, ob die Integration erfolgreich war:

  • Gehen Sie zu Seite Cloud SQL.

    Zu Cloud SQL

    Prüfen Sie die Datenbank und die Cloud SQL-Logs, um das Einfügen der neuen Zeile zu bestätigen.
  • Gehen Sie zu Seite Pub/Sub.

    Zu Pub/Sub

    Wählen Sie das Pub/Sub-Thema aus und klicken Sie auf Nachrichten anzeigen, um den Empfang der von der Integration gesendeten Nachricht zu bestätigen.
  • Prüfen Sie anhand der Application Integration-Logs den Status einer bestimmten Integration. So können die Logs angezeigt werden:
    1. Klicken Sie in der Symbolleiste des Integrationsdesigners auf Logs.
    2. Auf der Seite Ausführungslogs können Sie Details zu jedem Versuch anzeigen, eine Integration auszuführen. Jeder Eintrag enthält Details für den Ausführungsversuch. Beispiele:
      • Name der Integration
      • Ausführungs-ID
      • Status
      • Beginn
      • Dauer
      • Integrationsversion
      • Trigger-ID
    3. Klicken Sie neben der ausgeführten Integration auf den Erweiterungspfeil (>), um eine erweiterte Liste von Aufgaben und Variablen in der Integration aufzurufen. Außerdem werden der Aufgabenstatus und die Nutzlasten von Variablen angezeigt.