Terjemahan disediakan oleh mesin penerjemah. Jika konten terjemahan yang diberikan bertentangan dengan versi bahasa Inggris aslinya, utamakan versi bahasa Inggris.
# Memigrasi dan mereplikasi file VSAM ke Amazon RDS atau Amazon MSK menggunakan Connect from Excently
*Prachi Khanna dan Boopathy GOPALSAMY, Amazon Web Services*
## Ringkasan
[Pola ini menunjukkan kepada Anda cara memigrasi dan mereplikasi file Metode Akses Penyimpanan Virtual (VSAM) dari mainframe ke lingkungan target di AWS Cloud dengan menggunakan Connect from Accurly.](https://www.precisely.com/product/precisely-connect/connect) Lingkungan target yang tercakup dalam pola ini termasuk Amazon Relational Database Service (Amazon RDS) dan Amazon Managed Streaming for Apache Kafka (Amazon MSK). Connect menggunakan [change data capture (CDC)](https://www.precisely.com/resource-center/productsheets/change-data-capture-with-connect) untuk terus memantau pembaruan ke file VSAM sumber Anda dan kemudian mentransfer pembaruan ini ke satu atau beberapa lingkungan target AWS Anda. Anda dapat menggunakan pola ini untuk memenuhi tujuan modernisasi aplikasi atau analisis data Anda. Misalnya, Anda dapat menggunakan Connect untuk memigrasikan file aplikasi VSAM Anda ke AWS Cloud dengan latensi rendah, atau memigrasikan data VSAM Anda ke gudang data AWS atau data lake untuk analitik yang dapat mentolerir latensi sinkronisasi yang lebih tinggi dari yang diperlukan untuk modernisasi aplikasi.
## Prasyarat dan batasan
**Prasyarat**
+ [IBM z/OS V2R1](https://www-40.ibm.com/servers/resourcelink/svc00100.nsf/pages/zosv2r1-pdf-download?OpenDocument) atau yang lebih baru
+ [Server Transaksi CICS untuk z/OS (CICS TS) V5.1 atau yang lebih baru (pengambilan data CICS/VSAM](https://www.ibm.com/support/pages/cics-transaction-server-zos-51-detailed-system-requirements))
+ [IBM MQ 8.0](https://www.ibm.com/support/pages/downloading-ibm-mq-80) atau yang lebih baru
+ Kepatuhan dengan [persyaratan keamanan z/OS](https://help.precisely.com/r/Connect-CDC-SQData/4.1.43/en-US/Connect-CDC-SQData-Help/Installation/Install-Connect-CDC-SQData-on-zOS/Prerequisites-for-z/OS/Security-authorization-requirements-for-z/OS) (misalnya, otorisasi APF untuk pustaka pemuatan) SQData
+ Log pemulihan VSAM dihidupkan
+ (Opsional) [Versi Pemulihan CICS VSAM (CICS VR) untuk secara otomatis menangkap log CDC](https://www.ibm.com/docs/en/cics-vr/5.1?topic=started-introducing-cics-vr)
+ Akun AWS yang aktif
+ [Amazon Virtual Private Cloud (VPC)](https://docs.aws.amazon.com/vpc/latest/userguide/vpc-getting-started.html) dengan subnet yang dapat dijangkau oleh platform lama Anda
+ Lisensi VSAM Connect dari Tepatnya
**Batasan**
+ Connect tidak mendukung pembuatan tabel target otomatis berdasarkan skema atau copybook sumber VSAM. Anda harus menentukan struktur tabel target untuk pertama kalinya.
+ Untuk target non-streaming seperti Amazon RDS, Anda harus menentukan sumber konversi ke pemetaan target dalam skrip konfigurasi Apply Engine.
+ Fungsi pencatatan, pemantauan, dan peringatan diimplementasikan melalui APIs dan memerlukan komponen eksternal (seperti Amazon CloudWatch) untuk beroperasi penuh.
**Versi produk**
+ SQData 40134 untuk z/OS
+ SQData 4.0.43 untuk Amazon Linux Amazon Machine Image (AMI) di Amazon Elastic Compute Cloud (Amazon) EC2
## Arsitektur
**Tumpukan teknologi sumber**
+ Bahasa Kontrol Pekerjaan (JCL)
+ z/OS Unix shell dan Fasilitas Produktivitas Sistem Interaktif (ISPF)
+ Utilitas VSAM (IDCAMS)
**Tumpukan teknologi target**
+ Amazon EC2
+ Amazon MSK
+ Amazon RDS
+ Amazon VPC
**Arsitektur target**
*Memigrasi file VSAM ke Amazon RDS*
Diagram berikut menunjukkan cara memigrasikan file VSAM ke database relasional, seperti Amazon RDS, secara real time atau mendekati waktu nyata dengan menggunakan CDC agent/publisher di lingkungan sumber (mainframe lokal) dan [Apply Engine di](https://help.precisely.com/r/Connect-CDC-SQData/4.1.43/en-US/Connect-CDC-SQData-Help/Source-and-Target-Configuration/Apply-engine) lingkungan target (AWS Cloud).
Diagram menunjukkan alur kerja batch berikut:
1. Connect menangkap perubahan ke file dengan membandingkan file VSAM dari file cadangan untuk mengidentifikasi perubahan dan kemudian mengirimkan perubahan ke logstream.
1. Penerbit mengkonsumsi data dari logstream sistem.
1. Publisher mengkomunikasikan perubahan data yang ditangkap ke mesin target melalui TCP/IP. Controller Daemon mengotentikasi komunikasi antara sumber dan lingkungan target.
1. Apply Engine di lingkungan target menerima perubahan dari agen Publisher dan menerapkannya ke database relasional atau non-relasional.
Diagram menunjukkan alur kerja online berikut:
1. Connect menangkap perubahan dalam file online dengan menggunakan replika log dan kemudian mengalirkan perubahan yang ditangkap ke logstream.
1. Penerbit mengkonsumsi data dari logstream sistem.
1. Publisher mengkomunikasikan perubahan data yang ditangkap ke mesin target melalui TCP/IP. Controller Daemon mengotentikasi komunikasi antara sumber dan lingkungan target.
1. Apply Engine di lingkungan target menerima perubahan dari agen Publisher dan kemudian menerapkannya ke database relasional atau non-relasional.
*Migrasi file VSAM ke Amazon MSK*
Diagram berikut menunjukkan cara mengalirkan struktur data VSAM dari mainframe ke Amazon MSK dalam mode kinerja tinggi dan secara otomatis menghasilkan konversi skema JSON atau AVRO yang terintegrasi dengan Amazon MSK.
Diagram menunjukkan alur kerja batch berikut:
1. Connect menangkap perubahan ke file dengan menggunakan CICS VR atau dengan membandingkan file VSAM dari file cadangan untuk mengidentifikasi perubahan. Perubahan yang diambil dikirim ke logstream.
1. Penerbit mengkonsumsi data dari logstream sistem.
1. Publisher mengkomunikasikan perubahan data yang ditangkap ke mesin target melalui TCP/IP. Controller Daemon mengotentikasi komunikasi antara sumber dan lingkungan target.
1. Mesin Replicator yang beroperasi dalam mode pemrosesan paralel membagi data ke unit cache kerja.
1. Thread pekerja menangkap data dari cache.
1. Data dipublikasikan ke topik MSK Amazon dari utas pekerja.
1. [Pengguna menerapkan perubahan dari Amazon MSK ke target seperti Amazon DynamoDB, Amazon Simple Storage Service (Amazon S3) OpenSearch , atau Amazon Service dengan menggunakan konektor.](https://docs.aws.amazon.com/msk/latest/developerguide/msk-connect-connectors.html)
Diagram menunjukkan alur kerja online berikut:
1. Perubahan dalam file online ditangkap dengan menggunakan replika log. Perubahan yang ditangkap dialirkan ke logstream.
1. Penerbit mengkonsumsi data dari logstream sistem.
1. Publisher mengkomunikasikan perubahan data yang ditangkap ke mesin target melalui TCP/IP. Controller Daemon mengotentikasi komunikasi antara sumber dan lingkungan target.
1. Mesin Replicator yang beroperasi dalam mode pemrosesan paralel membagi data ke unit cache kerja.
1. Thread pekerja menangkap data dari cache.
1. Data dipublikasikan ke topik MSK Amazon dari utas pekerja.
1. [Pengguna menerapkan perubahan dari Amazon MSK ke target seperti DynamoDB, Amazon S3, atau Layanan dengan menggunakan konektor OpenSearch .](https://docs.aws.amazon.com/msk/latest/developerguide/msk-connect-connectors.html)
## Alat
+ [Amazon Managed Streaming for Apache Kafka (Amazon](https://docs.aws.amazon.com/msk/latest/developerguide/what-is-msk.html) MSK) adalah layanan yang dikelola sepenuhnya yang membantu Anda membangun dan menjalankan aplikasi yang menggunakan Apache Kafka untuk memproses data streaming.
+ [Amazon Relational Database Service (Amazon RDS](https://docs.aws.amazon.com/AmazonRDS/latest/UserGuide/Welcome.html)) membantu Anda menyiapkan, mengoperasikan, dan menskalakan database relasional di AWS Cloud.
## Epik
### Siapkan lingkungan sumber (mainframe)
| Tugas | Deskripsi | Keterampilan yang dibutuhkan |
| --- | --- | --- |
| Instal Connect CDC 4.1. | [See the AWS documentation website for more details](http://docs.aws.amazon.com/id_id/prescriptive-guidance/latest/patterns/migrate-and-replicate-vsam-files-to-amazon-rds-or-amazon-msk-using-connect-from-precisely.html) | Pengembang/Admin Mainframe IBM |
| Siapkan direktori ZFs. | Untuk menyiapkan direktori ZFs, ikuti instruksi dari [direktori variabel ZFs](https://help.precisely.com/r/Connect-CDC-SQData/4.1.43/en-US/Connect-CDC-SQData-Help/Installation/Install-Connect-CDC-SQData-on-zOS/Prerequisites-for-z/OS/Security-authorization-requirements-for-z/OS/zFS-variable-directories) di dokumentasi Tepat.Konfigurasi Daemon dan Capture/Publisher agen pengontrol disimpan dalam sistem file z/OS UNIX Systems Services (disebut sebagai ZFs). Agen Controller Daemon, Capture, Storage, dan Publisher memerlukan struktur direktori ZFs yang telah ditentukan untuk menyimpan sejumlah kecil file. | Pengembang/Admin Mainframe IBM |
| Konfigurasikan TCP/IP port. | Untuk mengkonfigurasi TCP/IP port, ikuti instruksi dari [port TCP/IP](https://help.precisely.com/r/Connect-CDC-SQData/4.1.43/en-US/Connect-CDC-SQData-Help/Installation/Install-Connect-CDC-SQData-on-UNIX/Prerequisites-for-UNIX/Security-authorization-requirements-for-UNIX/TCP/IP-ports) di dokumentasi Tepat.Daemon Controller membutuhkan TCP/IP port pada sistem sumber. Port direferensikan oleh mesin pada sistem target (di mana data perubahan yang ditangkap diproses). | Pengembang/Admin Mainframe IBM |
| Buat z/OS logstream. | Untuk membuat [logstream z/OS](https://www.ibm.com/docs/en/was/8.5.5?topic=SSEQTP_8.5.5/com.ibm.websphere.installation.zseries.doc/ae/cins_logstrm.html), ikuti instruksi dari [Buat LogStreams z/OS sistem di dokumentasi](https://help.precisely.com/r/Connect-CDC-SQData/4.1.43/en-US/Connect-CDC-SQData-Help/Source-and-Target-Configuration/Setup-and-configure-sources/IMS-z/OS/IMS-TM-EXIT-capture/Prepare-environment/Create-z/OS-system-logStreams?tocId=wy6243SXlIiEczwR8JE8WA) Tepatnya.Connect menggunakan logstream untuk menangkap dan mengalirkan data antara lingkungan sumber dan lingkungan target selama migrasi.
Untuk contoh JCL yang membuat z/OS LogStream, lihat [Membuat z/OS sistem LogStreams](https://help.precisely.com/r/Connect-CDC-SQData/4.1.43/en-US/Connect-CDC-SQData-Help/Source-and-Target-Configuration/Setup-and-configure-sources/IMS-z/OS/IMS-TM-EXIT-capture/Prepare-environment/Create-z/OS-system-logStreams?tocId=wy6243SXlIiEczwR8JE8WA) dalam dokumentasi Tepatnya. | Pengembang Mainframe IBM |
| Identifikasi dan otorisasi IDs untuk pengguna ZF dan mulai tugas. | Gunakan RACF untuk memberikan akses ke sistem file OMVS ZFS. Untuk contoh JCL, lihat [Mengidentifikasi dan mengotorisasi pengguna ZFs dan memulai tugas IDs dalam dokumentasi Tepatnya](https://help.precisely.com/r/Connect-CDC-SQData/4.1.43/en-US/Connect-CDC-SQData-Help/Source-and-Target-Configuration/Setup-and-configure-sources/IMS-z/OS/IMS-log-reader-capture/Prepare-environment/Identify-and-authorize-zFS-user-and-started-task-IDs?tocId=MrBXpFu~N0iAy~8VTrH0tQ). | Pengembang/Admin Mainframe IBM |
| Hasilkan kunci z/OS publik/pribadi dan file kunci resmi. | Jalankan JCL untuk menghasilkan key pair. Sebagai contoh, lihat *Contoh pasangan kunci* di bagian *Informasi tambahan* dari pola ini.
Untuk petunjuk, lihat [Menghasilkan kunci z/OS publik dan pribadi serta file kunci resmi](https://help.precisely.com/r/Connect-CDC-SQData/4.1.43/en-US/Connect-CDC-SQData-Help/Source-and-Target-Configuration/Setup-and-configure-sources/Db2-z/OS/Prepare-the-environment/Generate-z/OS-public-and-private-keys-and-authorized-key-file?tocId=fceE77dWT8smZsSaE~FeMQ) dalam dokumentasi Tepatnya. | Pengembang/Admin Mainframe IBM |
| Aktifkan Replikasi Log CICS VSAM dan lampirkan ke logstream. | Jalankan skrip JCL berikut: //STEP1 EXEC PGM=IDCAMS
//SYSPRINT DD SYSOUT=*
//SYSIN DD *
ALTER SQDATA.CICS.FILEA -
LOGSTREAMID(SQDATA.VSAMCDC.LOG1) -
LOGREPLICATE
| Pengembang/Admin Mainframe IBM |
| Aktifkan Log Pemulihan File VSAM melalui FCT. | Ubah File Control Table (FCT) untuk mencerminkan perubahan parameter berikut: Configure FCT Parms
CEDA ALT FILE(name) GROUP(groupname)
DSNAME(data set name)
RECOVERY(NONE|BACKOUTONLY|ALL)
FWDRECOVLOG(NO|1–99)
BACKUPTYPE(STATIC|DYNAMIC)
RECOVERY PARAMETERS
RECOVery : None | Backoutonly | All
Fwdrecovlog : No | 1-99
BAckuptype : Static | Dynamic
| Pengembang/Admin Mainframe IBM |
| Siapkan CDCz Log untuk agen Penerbit. | [See the AWS documentation website for more details](http://docs.aws.amazon.com/id_id/prescriptive-guidance/latest/patterns/migrate-and-replicate-vsam-files-to-amazon-rds-or-amazon-msk-using-connect-from-precisely.html) | Pengembang/Admin Mainframe IBM |
| Aktifkan Daemon Pengontrol. | [See the AWS documentation website for more details](http://docs.aws.amazon.com/id_id/prescriptive-guidance/latest/patterns/migrate-and-replicate-vsam-files-to-amazon-rds-or-amazon-msk-using-connect-from-precisely.html) | Pengembang/Admin Mainframe IBM |
| Aktifkan penerbit. | [See the AWS documentation website for more details](http://docs.aws.amazon.com/id_id/prescriptive-guidance/latest/patterns/migrate-and-replicate-vsam-files-to-amazon-rds-or-amazon-msk-using-connect-from-precisely.html) | Pengembang/Admin Mainframe IBM |
| Aktifkan logstream. | [See the AWS documentation website for more details](http://docs.aws.amazon.com/id_id/prescriptive-guidance/latest/patterns/migrate-and-replicate-vsam-files-to-amazon-rds-or-amazon-msk-using-connect-from-precisely.html) | Pengembang/Admin Mainframe IBM |
### Siapkan lingkungan target (AWS)
| Tugas | Deskripsi | Keterampilan yang dibutuhkan |
| --- | --- | --- |
| Instal Tepat pada sebuah EC2 instance. | Untuk menginstal Connect from Tepat di Amazon Linux AMI untuk Amazon EC2, ikuti petunjuk dari [Install Connect CDC (SQData) pada UNIX dalam dokumentasi](https://help.precisely.com/r/Connect-CDC-SQData/4.1.43/en-US/Connect-CDC-SQData-Help/Installation/Install-Connect-CDC-SQData-on-UNIX) Tepat. | AWS Umum |
| Buka TCP/IP port. | Untuk memodifikasi grup keamanan untuk menyertakan port Daemon Pengontrol untuk akses masuk dan keluar, ikuti instruksi dari [TCP/IP](https://help.precisely.com/r/Connect-CDC-SQData/4.1.43/en-US/Connect-CDC-SQData-Help/Source-and-Target-Configuration/Setup-and-configure-sources/Change-data-capture/Transient-storage-and-publishing/TCP/IP) dalam dokumentasi Tepatnya. | AWS Umum |
| Buat direktori file. | Untuk membuat direktori file, ikuti petunjuk dari [Siapkan lingkungan penerapan target](https://help.precisely.com/r/Connect-CDC-SQData/4.1.43/en-US/Connect-CDC-SQData-Help/Source-and-Target-Configuration/Setup-and-configure-targets/Kafka/Prepare-target-apply-environment) dalam dokumentasi Tepat. | AWS Umum |
| Buat file konfigurasi Apply Engine. | Buat file konfigurasi Apply Engine di direktori kerja Apply Engine. Contoh file konfigurasi berikut menunjukkan Apache Kafka sebagai target:builtin.features=SASL_SCRAM
security.protocol=SASL_SSL
sasl.mechanism=SCRAM-SHA-512
sasl.username=
sasl.password=
metadata.broker.list=
Untuk informasi selengkapnya, lihat [Keamanan](https://kafka.apache.org/documentation/#security) dalam dokumentasi Apache Kafka. | AWS Umum |
| Buat skrip untuk pemrosesan Apply Engine. | Buat skrip untuk Apply Engine untuk memproses data sumber dan mereplikasi data sumber ke target. Untuk informasi selengkapnya, lihat [Membuat skrip mesin terapkan](https://help.precisely.com/r/Connect-CDC-SQData/4.1.43/en-US/Connect-CDC-SQData-Help/Source-and-Target-Configuration/Apply-engine/Apply-engine-script-development/Create-an-apply-engine-script) di dokumentasi Tepatnya. | AWS Umum |
| Jalankan skrip. | Gunakan `SQDENG` perintah `SQDPARSE` dan untuk menjalankan skrip. Untuk informasi selengkapnya, lihat [Mengurai skrip untuk ZoS](https://help.precisely.com/r/Connect-CDC-SQData/4.1.43/en-US/Connect-CDC-SQData-Help/Source-and-Target-Configuration/Apply-engine/Apply-engine-script-development/Parse-a-script/Parse-a-script-for-zOS) di dokumentasi Tepatnya. | AWS Umum |
### Validasi lingkungan
| Tugas | Deskripsi | Keterampilan yang dibutuhkan |
| --- | --- | --- |
| Validasi daftar file VSAM dan tabel target untuk pemrosesan CDC. | [See the AWS documentation website for more details](http://docs.aws.amazon.com/id_id/prescriptive-guidance/latest/patterns/migrate-and-replicate-vsam-files-to-amazon-rds-or-amazon-msk-using-connect-from-precisely.html) | AWS Umum, Mainframe |
| Verifikasi bahwa SQData produk Connect CDC ditautkan. | Jalankan pekerjaan pengujian dan verifikasi bahwa kode pengembalian dari pekerjaan ini adalah 0 (Berhasil).Connect CDC SQData Apply Engine pesan status harus menampilkan pesan koneksi aktif. | AWS Umum, Mainframe |
### Jalankan dan validasi kasus uji (Batch)
| Tugas | Deskripsi | Keterampilan yang dibutuhkan |
| --- | --- | --- |
| Jalankan pekerjaan batch di mainframe. | Jalankan pekerjaan aplikasi batch menggunakan JCL yang dimodifikasi. Sertakan langkah-langkah dalam JCL yang dimodifikasi yang melakukan hal berikut:[See the AWS documentation website for more details](http://docs.aws.amazon.com/id_id/prescriptive-guidance/latest/patterns/migrate-and-replicate-vsam-files-to-amazon-rds-or-amazon-msk-using-connect-from-precisely.html) | AWS Umum, Mainframe |
| Periksa logstream. | Periksa logstream untuk mengonfirmasi bahwa Anda dapat melihat data perubahan untuk pekerjaan batch mainframe yang telah selesai. | AWS Umum, Mainframe |
| Validasi jumlah untuk perubahan delta sumber dan tabel target. | Untuk mengonfirmasi bahwa catatan dihitung, lakukan hal berikut:[See the AWS documentation website for more details](http://docs.aws.amazon.com/id_id/prescriptive-guidance/latest/patterns/migrate-and-replicate-vsam-files-to-amazon-rds-or-amazon-msk-using-connect-from-precisely.html) | AWS Umum, Mainframe |
### Jalankan dan validasi kasus uji (Online)
| Tugas | Deskripsi | Keterampilan yang dibutuhkan |
| --- | --- | --- |
| Jalankan transaksi online di wilayah CICS. | [See the AWS documentation website for more details](http://docs.aws.amazon.com/id_id/prescriptive-guidance/latest/patterns/migrate-and-replicate-vsam-files-to-amazon-rds-or-amazon-msk-using-connect-from-precisely.html) | Pengembang Mainframe IBM |
| Periksa logstream. | Konfirmasikan bahwa logstream diisi dengan perubahan tingkat catatan tertentu. | Pengembang AWS Mainframe |
| Validasi hitungan dalam database target. | Pantau Apply Engine untuk mencatat jumlah level. | Tepatnya, Linux |
| Validasi jumlah catatan dan catatan data dalam database target. | Kueri database target untuk memvalidasi jumlah catatan dan catatan data. | AWS Umum |
## Sumber daya terkait
+ [VSAM z/OS (Dokumentasi tepatnya](https://help.precisely.com/r/Connect-CDC-SQData/4.1.43/en-US/Connect-CDC-SQData-Help/Source-and-Target-Configuration/Setup-and-configure-sources/VSAM-z/OS))
+ [Terapkan mesin](https://help.precisely.com/r/Connect-CDC-SQData/4.1.43/en-US/Connect-CDC-SQData-Help/Source-and-Target-Configuration/Apply-engine) (Tepatnya dokumentasi)
+ [Mesin replikator](https://help.precisely.com/r/Connect-CDC-SQData/4.1.43/en-US/Connect-CDC-SQData-Help/Source-and-Target-Configuration/Replicator-engine) (Dokumentasi tepatnya)
+ [Aliran log](https://www.ibm.com/docs/en/zos/2.3.0?topic=logger-log-stream) (dokumentasi IBM)
## Informasi tambahan
**Contoh file konfigurasi**
Ini adalah contoh file konfigurasi untuk logstream di mana lingkungan sumber adalah mainframe dan lingkungan target adalah Amazon MSK:
```
-- JOBNAME -- PASS THE SUBSCRIBER NAME
-- REPORT progress report will be produced after "n" (number) of Source records processed.
JOBNAME VSMTOKFK;
--REPORT EVERY 100;
-- Change Op has been ‘I’ for insert, ‘D’ for delete , and ‘R’ for Replace. For RDS it is 'U' for update
-- Character Encoding on z/OS is Code Page 1047, on Linux and UNIX it is Code Page 819 and on Windows, Code Page 1252
OPTIONS
CDCOP('I', 'U', 'D'),
PSEUDO NULL = NO,
USE AVRO COMPATIBLE NAMES,
APPLICATION ENCODING SCHEME = 1208;
-- SOURCE DESCRIPTIONS
BEGIN GROUP VSAM_SRC;
DESCRIPTION COBOL ../copybk/ACCOUNT AS account_file;
END GROUP;
-- TARGET DESCRIPTIONS
BEGIN GROUP VSAM_TGT;
DESCRIPTION COBOL ../copybk/ACCOUNT AS account_file;
END GROUP;
-- SOURCE DATASTORE (IP & Publisher name)
DATASTORE cdc://10.81.148.4:2626/vsmcdct/VSMTOKFK
OF VSAMCDC
AS CDCIN
DESCRIBED BY GROUP VSAM_SRC ACCEPT ALL;
-- TARGET DATASTORE(s) - Kafka and topic name
DATASTORE 'kafka:///MSKTutorialTopic/key'
OF JSON
AS CDCOUT
DESCRIBED BY GROUP VSAM_TGT FOR INSERT;
-- MAIN SECTION
PROCESS INTO
CDCOUT
SELECT
{
SETURL(CDCOUT, 'kafka:///MSKTutorialTopic/key')
REMAP(CDCIN, account_file, GET_RAW_RECORD(CDCIN, AFTER), GET_RAW_RECORD(CDCIN, BEFORE))
REPLICATE(CDCOUT, account_file)
}
FROM CDCIN;
```
**Contoh pasangan kunci**
Ini adalah contoh bagaimana menjalankan JCL untuk menghasilkan key pair:
```
//SQDUTIL EXEC PGM=SQDUTIL //SQDPUBL DD DSN=&USER..NACL.PUBLIC, // DCB=(RECFM=FB,LRECL=80,BLKSIZE=21200), // DISP=(,CATLG,DELETE),UNIT=SYSDA, // SPACE=(TRK,(1,1)) //SQDPKEY DD DSN=&USER..NACL.PRIVATE, // DCB=(RECFM=FB,LRECL=80,BLKSIZE=21200), // DISP=(,CATLG,DELETE),UNIT=SYSDA, // SPACE=(TRK,(1,1)) //SQDPARMS DD keygen //SYSPRINT DD SYSOUT= //SYSOUT DD SYSOUT=* //SQDLOG DD SYSOUT=* //*SQDLOG8 DD DUMMY
```