Memublikasikan pesan ke Pub/Sub dari mainframe

Mainframe Connector memungkinkan Anda memublikasikan pesan ke Pub/Sub dari mainframe. Anda dapat menggunakan fitur ini, misalnya, untuk mengintegrasikan mainframe dengan BigQuery atau Cloud Storage, menambah data pesan dengan Dataflow, atau memicu fungsi Cloud Run.

Sebelum memulai

Memublikasikan pesan ke topik Pub/Sub

Untuk memublikasikan pesan Pub/Sub yang tidak terstruktur dari mainframe, gunakan perintah pubsub topics publish sebagai berikut:

//STEP01 EXEC BQSH
//STDIN DD *
pubsub topics publish TOPIC --data="Hello,World"
/*

Ganti TOPIC dengan nama topik Pub/Sub. Format yang diperlukan adalah projects/{project}/topics/{topic}.

Memublikasikan pesan ke topik Pub/Sub

Mainframe Connector memungkinkan Anda memublikasikan pesan terstruktur dari mainframe ke topik Pub/Sub. Misalnya, Anda dapat menggunakan kemampuan ini untuk mentransfer data Queued Sequential Access Method (QSAM) dari mainframe ke BigQuery menggunakan Pub/Sub. Berikut beberapa keuntungan menggunakan pendekatan ini:

  • Anda dapat mengubah data atau meningkatkan data dengan AI melalui Dataflow atau melalui multithreading simultan (SMT) Pub/Sub.
  • Anda dapat memindahkan data dari mainframe ke Cloud Storage.
  • Anda dapat menyinkronkan update aplikasi mainframe ke sistem berbasis cloud yang mirip dengan pengambilan data perubahan (CDC).

Untuk memublikasikan pesan terstruktur dari mainframe ke topik Pub/Sub, gunakan langkah-langkah berikut:

  1. Buat topik Pub/Sub untuk memublikasikan pesan. Jika ingin, Anda dapat membuat topik dengan skema untuk pembatasan lainnya. Untuk mengetahui informasi selengkapnya, lihat Membuat topik atau Membuat dan mengaitkan skema saat Anda membuat topik.
  2. Buat topik Pub/Sub untuk mengambil informasi tentang data yang gagal ditranskode. Topik ini disebut topik spillover. Untuk mengetahui informasi tentang cara membuat topik Pub/Sub, lihat Membuat topik.
  3. (Opsional) Untuk mengonversi data ke JSON sebelum mengirimnya ke Pub/Sub, konfigurasikan file konfigurasi JSON. Jika Anda tidak memberikan file konfigurasi, konfigurasi JSON default akan digunakan.
  4. (Opsional) Secara default, pesan Pub/Sub tidak berisi kunci urutan, dan atribut. Pesan tambahan dikirim ke topik tambahan dengan akhiran _spillover. Untuk mengubah setelan default, Anda dapat mengonfigurasi file konfigurasi publikasi Pub/Sub. Misalnya, Anda dapat menggunakan konfigurasi berikut:

    {
      "spillover-configuration": {
        "name": SPILLOVER_TOPIC_NAME
      }
    }
    

    Ganti SPILLOVER_TOPIC_NAME dengan nama topik tambahan yang Anda buat di langkah 2. Format yang diperlukan adalah projects/{project}/topics/{topic}. Informasi tentang pesan yang tidak didekode dengan benar disimpan ke topik tambahan ini.

  5. Untuk memublikasikan data mainframe ke Pub/Sub menggunakan perintah qsam decode, jalankan JCL berikut:

    //STEP01 EXEC BQSH
    //STDIN DD *
    qsam decode INPUT OUTPUT \
     --copybook COPYBOOK
     --transcode-configuration TRANSCODE-CONFIG
         --output-format=JSONL
         --input-parameter=json-dialect=JSON_CONFIGURATION
         --input-parameter=pubsub-publish-configuration=PUBSUB_CONFIGURATION
    /*
    

    Ganti kode berikut:

    • INPUT: jalur data file QSAM.
    • OUTPUT: jalur data topik Pub/Sub yang Anda buat di langkah 1. Format yang diperlukan adalah pubsub:projects/{project}/topics/{topic}.
    • TRANSCODE-CONFIG: jalur data file yang berisi konfigurasi transcoding. Untuk mengetahui informasi selengkapnya tentang format konfigurasi transcoder, lihat Konfigurasi transcoder.
    • JSON_CONFIGURATION: (opsional) jalur data dari file konfigurasi JSON. Jika Anda tidak memberikan file konfigurasi, konfigurasi JSON default akan digunakan.
    • PUBSUB_CONFIGURATION: (opsional) jalur data dari file konfigurasi publikasi Pub/Sub. Jika Anda tidak menentukan file konfigurasi, konfigurasi Pub/Sub default akan digunakan.