Lihat konektor yang didukung untuk Integration Aplikasi.

Memanggil integrasi untuk peristiwa Salesforce Change Data Capture (CDC)

Pelajari cara membuat contoh integrasi di Integrasi Aplikasi menggunakan pemicu Salesforce. Langkah-langkah berikut menjelaskan cara mengonfigurasi pemicu, tugas, konektor, dan pemetaan data yang diperlukan untuk menjalankan integrasi lengkap.

Dalam panduan memulai ini, Anda akan menggunakan pemicu Salesforce untuk memanggil integrasi di Integrasi Aplikasi untuk peristiwa Salesforce Change Data Capture (CDC) seperti yang ditunjukkan pada gambar berikut:

Contoh diagram urutan Contoh diagram urutan

Pemicu Salesforce berlangganan ke saluran peluang Salesforce. Perubahan data pada peluang Salesforce akan memanggil Integrasi Aplikasi yang mengekstrak status peluang Salesforce. Jika statusnya ditutup, integrasi akan mengekstrak detail peluang dan menulis data ke instance Cloud SQL menggunakan konektor. Jika ada perubahan data, tetapi status tetap terbuka, integrasi akan mengirimkan pesan ke topik pub/sub menggunakan konektor.

Langkah-langkah berikut menjelaskan cara mengonfigurasi pemicu, tugas, profil autentikasi, edge, variabel, dan pemetaan data yang diperlukan untuk menjalankan integrasi yang berhasil.

Sebelum memulai

  • Pastikan akun developer Salesforce Anda telah mengaktifkan Change Data Capture (CDC). Tutorial ini mengasumsikan bahwa Anda sudah memiliki akun developer Salesforce dengan penyiapan pengguna dan setelan izin yang diperlukan. Untuk informasi tentang penyiapan pengguna dan kumpulan izin Salesforce, lihat Mengonfigurasi pemicu Salesforce.
  • Tetapkan peran IAM berikut ke Agen Layanan Integrasi Aplikasi(service-PROJECT_NUMBER@gcp-sa-integrations.iam.gserviceaccount.com) di project Google Cloud Anda.
    • Editor Pub/Sub
    • Connectors Admin
    • Application Integration Invoker
    Untuk mengetahui informasi selengkapnya tentang cara menetapkan peran IAM, lihat Peran dan izin IAM.
  • Buat tabel Cloud SQL untuk menyimpan data CDC Salesforce.
    1. Di konsol Google Cloud, buka halaman Instance Cloud SQL dan hubungkan ke instance MySQL Anda. Lihat Menghubungkan ke Cloud SQL untuk MySQL dari Cloud Shell.

      Buka instance Cloud SQL

    2. Buat database MySQL berikut di instance Cloud SQL Anda: 
      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. Pastikan tabel dibuat dengan menjalankan perintah berikut. 
      SELECT * FROM OPPORTUNITIES;
  • Buat koneksi Cloud SQL untuk MySQL di Konektor. Lihat Membuat koneksi Cloud SQL untuk MySQL untuk mengetahui informasi mendetail.
  • Buat koneksi Cloud Pub/Sub di Konektor. Lihat Membuat koneksi Cloud Pub/Sub untuk mengetahui informasi mendetail.

Membuat integrasi baru

Untuk membuat integrasi baru, lakukan langkah-langkah berikut:

  1. Di konsol Google Cloud, buka halaman Integrasi Aplikasi.

    Buka Application Integration

  2. Di menu navigasi, klik Integrations. Halaman Integrations akan muncul.
  3. Klik Create integration.
  4. Masukkan nama dan deskripsi di dialog Buat Integrasi. Contoh, Demo-CDC-Opportunities.
  5. Pilih region untuk integrasi.
  6. Klik Buat untuk membuka desainer integrasi.

Menambahkan dan mengonfigurasi pemicu Salesforce

Untuk menambahkan dan mengonfigurasi pemicu Salesforce ke integrasi, lakukan langkah-langkah berikut:

  1. Di desainer integrasi, pilih Tambahkan tugas/pemicu > Pemicu untuk menampilkan daftar pemicu yang tersedia.
  2. Klik dan tempatkan elemen Pemicu Salesforce di desainer integrasi.
  3. Klik elemen Salesforce trigger di kanvas untuk membuka panel konfigurasi pemicu.
  4. Konfigurasikan kolom berikut di bagian Input Pemicu:
    • Jenis peristiwa: Pilih Change Data Capture (CDC) dari menu drop-down.
    • Konfigurasi instance Salesforce: Klik opsi + Tambahkan konfigurasi instance Salesforce baru dari daftar drop-down.

      Dialog Tambahkan konfigurasi instance Salesforce akan muncul.

      • Nama koneksi instance Salesforce: Masukkan nama koneksi untuk instance Salesforce. Contoh, CDC-PlatformUser.
      • Domain Salesforce: Masukkan nama domain Salesforce Anda. Anda dapat menemukan informasi ini dari halaman Akun Salesforce > Lihat profil.
      • Profil autentikasi: Pilih profil autentikasi. Jika Anda tidak memiliki profil autentikasi, buat profil baru. Untuk mengetahui informasinya, lihat Membuat profil autentikasi baru.
      • Klik Tambahkan.
    • Konfigurasi saluran Salesforce: Klik opsi + Tambahkan konfigurasi saluran Salesforce baru dari daftar drop-down.

      Dialog Tambahkan saluran Salesforce akan muncul.

      • Nama objek Salesforce: Masukkan Opportunity.
      • Klik Tambahkan.
    • Operasi: Pilih Update dari menu drop-down

    Perubahan pada properti akan disimpan secara otomatis.

Menambahkan dan mengonfigurasi tugas

Tutorial ini menggunakan tugas Konektor dan Pemetaan Data. Detail konfigurasi untuk setiap tugas ini dijelaskan sebagai berikut.

Mengonfigurasi tugas Konektor dengan koneksi Cloud SQL untuk MySQL

Lakukan langkah-langkah berikut untuk mengonfigurasi tugas Konektor guna menyisipkan data ke tabel Cloud SQL yang ada menggunakan koneksi Cloud SQL untuk MySQL:

  1. Pilih +Tambahkan tugas/pemicu > Tugas di desainer integrasi untuk menampilkan daftar tugas yang tersedia.
  2. Klik dan tempatkan elemen Konektor di desainer integrasi.
  3. Klik elemen tugas Konektor di desainer untuk melihat panel konfigurasi tugas konektor.
  4. Klik dan ubah nama Konektor menjadi Insert row to Cloud SQL.
  5. Klik Configure task.

    Dialog Configure connector task akan muncul.

  6. Lakukan hal berikut di dialog Configure connector task:
    1. Pilih region koneksi.
    2. Setelah region dipilih, kolom Koneksi akan muncul. Pilih koneksi Cloud SQL untuk MySQL dari daftar koneksi yang tersedia.
    3. Setelah koneksi dipilih, kolom Jenis akan muncul. Pilih Entities, lalu OPPORTUNITIES dari daftar entity yang tersedia.
    4. Setelah jenis dipilih, kolom Operasi akan muncul. Pilih Buat.
    5. Klik Done untuk menyelesaikan konfigurasi koneksi dan menutup panel.

Mengonfigurasi tugas Konektor dengan koneksi Cloud Pub/Sub

Lakukan langkah-langkah berikut untuk mengonfigurasi tugas Konektor guna memublikasikan pesan Pub/Sub menggunakan koneksi Cloud Pub/Sub:

  1. Pilih +Tambahkan tugas/pemicu > Tugas di desainer integrasi untuk menampilkan daftar tugas yang tersedia.
  2. Klik dan tempatkan elemen Konektor di desainer integrasi.
  3. Klik elemen tugas Konektor di desainer untuk melihat panel konfigurasi tugas konektor.
  4. Klik dan ubah nama Konektor menjadi Publish to cloud pub/sub.
  5. Klik Configure task.

    Dialog Configure connector task akan muncul.

  6. Lakukan hal berikut di dialog Configure connector task:
    1. Pilih region koneksi.
    2. Setelah region dipilih, kolom Koneksi akan muncul. Pilih koneksi Pub/Sub Anda dari daftar koneksi yang tersedia.
    3. Setelah koneksi dipilih, kolom Jenis akan muncul. Pilih Actions, lalu publishMessage dari daftar tindakan yang tersedia.
    4. Klik Done untuk menyelesaikan konfigurasi koneksi dan menutup panel.

Mengonfigurasi tugas Pemetaan Data

Lakukan langkah-langkah berikut untuk mengonfigurasi tugas Pemetaan Data:

  1. Pilih Tambahkan tugas/pemicu > Tugas untuk menampilkan daftar tugas yang tersedia.
  2. Klik dan tempatkan elemen Pemetaan Data di desainer integrasi.
  3. Klik elemen Pemetaan Data di desainer untuk membuka panel konfigurasi tugas.
  4. Klik Buka Editor Pemetaan Data.

    Editor Pemetaan Data memungkinkan Anda memetakan variabel input ke variabel output yang diinginkan, menggunakan fungsi transformasi yang tersedia. Output kemudian tersedia sebagai variabel untuk tugas atau pemicu integrasi lainnya. Untuk mengetahui detail selengkapnya tentang meneruskan data sebagai variabel, lihat Menggunakan variabel dalam Integrasi Aplikasi.

  5. Klik + Tambahkan variabel baru dan buat variabel output berikut:
    Nama variabel output Jenis data
    OpportunityIsClosed Boolean
    OpportunityId String
    PubSubMessage String
  6. Buat pemetaan berikut antara variabel SalesforceTriggerCdcPayload dan variabel Connector input payload seperti yang ditunjukkan dalam tabel berikut:
    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. Setelah pemetaan selesai, tutup panel. Setiap perubahan akan otomatis disimpan.

Menambahkan koneksi tepi

Edge adalah koneksi antara dua elemen dalam integrasi dan kondisi edge memungkinkan Anda menentukan kondisi yang harus dipenuhi agar kontrol integrasi dapat diteruskan ke tugas yang terhubung oleh edge. Untuk informasi selengkapnya tentang tepi dan kondisi tepi, lihat Tepi.

  1. Tambahkan koneksi edge dari elemen Pemicu Salesforce ke elemen Pemetaan Data.
  2. Tambahkan koneksi edge dari elemen Pemetaan Data ke elemen Sisipkan baris ke Konektor Cloud SQL dengan kondisi edge berikut: 
      $OpportunityIsClosed$ = TRUE
  3. Tambahkan koneksi edge lain dari elemen Pemetaan Data ke elemen Konektor Cloud Pub/Sub dengan kondisi edge berikut: 
      $OpportunityIsClosed$ = FALSE
Contoh gambar yang menunjukkan koneksi tepi Contoh gambar yang menunjukkan koneksi tepi

Menguji integrasi

Untuk menguji integrasi baru:

  1. Klik Uji di toolbar desainer integrasi, lalu pilih Pemicu Salesforce.

    Dialog Test Integration akan muncul.

  2. Klik Uji integrasi.

Uji tugas Cloud SQL dengan login ke instance Salesforce dan mengubah status peluang menjadi "tertutup".

Uji tugas Pub/Sub dengan login ke instance Salesforce dan mengubah detail lain tentang peluang, tetapi biarkan status peluang "terbuka".

Untuk informasi selengkapnya tentang pengujian, lihat Menguji dan memublikasikan integrasi.

Untuk memverifikasi keberhasilan integrasi Anda:

  • Buka halaman Cloud SQL.

    Buka Cloud SQL

    Periksa database dan log Cloud SQL Anda untuk mengonfirmasi penyisipan baris baru.
  • Buka halaman Pub/Sub.

    Buka Pub/Sub

    Pilih topik Pub/Sub, lalu klik Lihat pesan untuk mengonfirmasi penerimaan pesan yang dikirim oleh integrasi.
  • Periksa log Integrasi Aplikasi untuk melihat status integrasi tertentu. Untuk melihat log:
    1. Klik Logs di toolbar desainer integrasi.
    2. Di halaman Log Eksekusi, Anda dapat melihat detail tentang setiap upaya untuk menjalankan integrasi. Setiap entri menyertakan detail untuk upaya eksekusi, termasuk:
      • Nama integrasi
      • ID eksekusi
      • Status
      • Waktu mulai
      • Durasi
      • Versi integrasi
      • ID Pemicu
    3. Klik panah peluas (>) di samping integrasi yang dieksekusi untuk melihat daftar tugas dan variabel yang diperluas dalam integrasi, beserta status tugas dan payload variabel.