Integrasikan pemrosesan model AI ke dalam pipeline Data Integration DataWorks untuk menganalisis, memproses, dan meningkatkan data secara real time saat data berpindah dari sumber ke tujuan, sehingga membuka nilai tersembunyi dari data tidak terstruktur.
Fitur
Pengguna target: Pengguna perusahaan yang memerlukan analisis dan pemrosesan berbasis AI selama sinkronisasi data untuk meningkatkan kualitas data dan mengekstraksi nilai data.
Integrasi mulus: Pemrosesan AI merupakan langkah bawaan dalam Data Integration yang terhubung secara mulus dengan pembacaan dari sumber dan penulisan ke tujuan.
Dukungan untuk berbagai tugas NLP: Anda dapat menjalankan beberapa tugas natural language processing (NLP) pada data teks selama sinkronisasi, seperti analisis sentimen, pembuatan ringkasan, ekstraksi kata kunci, dan terjemahan teks.
Kasus penggunaan
Industri | Aplikasi khas |
Layanan pelanggan / E-dagang | Analisis sentimen komentar pengguna dan tiket layanan pelanggan secara real time. Ekstrak secara otomatis masalah inti dan titik umpan balik utama. |
Kepatuhan / Hukum / Penelitian ilmiah | Saat sinkronisasi, hasilkan ringkasan secara otomatis dan ekstrak informasi kunci dari dokumen kebijakan, kontrak hukum, dan makalah penelitian. |
Manufaktur / Rantai pasok / Kesehatan | Analisis secara cerdas log perangkat, umpan balik rantai pasok, atau catatan komunikasi dokter-pasien untuk mengaktifkan peringatan risiko dan optimalisasi kualitas layanan. |
Kolaborasi lintas bahasa | Terjemahkan secara otomatis komentar media sosial, artikel berita, atau dokumen bisnis dari seluruh dunia ke dalam satu bahasa selama sinkronisasi untuk memudahkan analisis terpusat. |
Prasyarat
Anda telah membuat ruang kerja yang menggunakan Data Studio (versi baru).
Anda telah menyiapkan layanan model besar yang diperlukan untuk pemrosesan konten AI. Langkah persiapan bergantung pada penyedia model yang Anda pilih:
Layanan Model DataWorks: Anda telah men-deploy model di Manajemen Layanan Model dan memulai layanan model tersebut.
Model Studio: Anda telah mengaktifkan Model Studio dan memperoleh Kunci API.
PAI-Marketplace: Anda telah mengaktifkan Platform for AI (PAI) dan memperoleh token untuk layanan model.
Untuk tugas sinkronisasi batch, Anda dapat mengonfigurasi detail sumber data secara manual atau menggunakan sumber data yang sudah ada.
Pastikan ruang kerja telah ditautkan ke kelompok sumber daya dan kelompok sumber daya tersebut dapat terhubung ke sumber data.
Penagihan
Selain biaya standar Data Integration, tugas pemrosesan konten AI akan dikenai biaya pemanggilan model besar:
Untuk rincian penagihan Layanan Model DataWorks, lihat Penagihan kelompok sumber daya arsitektur tanpa server untuk layanan model besar.
Untuk rincian penagihan Model Studio, lihat Biaya inferensi model (pemanggilan).
Untuk rincian penagihan PAI-Marketplace, lihat Penagihan Elastic Algorithm Service (EAS).
Contoh
Contoh ini menyinkronkan data antara dua tabel Hologres, menerjemahkan kolom feedback_info ke dalam bahasa Inggris, dan menulis hasilnya ke tabel tujuan.
Langkah 1: Buat tugas sinkronisasi batch
Buka halaman Ruang Kerja di Konsol DataWorks. Di bilah navigasi atas, pilih wilayah yang diinginkan. Temukan ruang kerja yang diinginkan dan pilih di kolom Actions.
Di panel navigasi kiri, klik
untuk menuju halaman pengembangan data. Di sebelah kanan Project Directory, klik
dan pilih . Kotak dialog Create Node akan muncul.Atur Path, Data source destination, dan Name node. Lalu, klik OK untuk membuat node sinkronisasi batch.
Dokumen ini menggunakan contoh tugas sinkronisasi Hologres-ke-Hologres untuk menunjukkan fitur pemrosesan konten AI dalam tugas sinkronisasi batch.
Langkah 2: Konfigurasikan tugas sinkronisasi
Setelah Anda membuat node sinkronisasi batch, editor tugas akan terbuka. Konfigurasikan pengaturan berikut:
1. Sumber data
Konfigurasikan sumber data dan tujuan data.
Type: Anda memilih jenis sumber data dan tujuan data pada langkah Buat tugas sinkronisasi batch. Jenis ini tidak dapat diubah. Untuk menggunakan jenis berbeda, Anda harus membuat tugas sinkronisasi batch baru.
Data Source: Pilih sumber data Hologres yang ditautkan ke ruang kerja, atau pilih Add Data Source dari daftar drop-down.
2. Sumber daya runtime
Pilih Resource Group untuk tugas sinkronisasi. Jika Anda menggunakan kelompok sumber daya arsitektur tanpa server, Anda juga dapat menentukan Resource Usage (CU) untuk tugas tersebut.
Setelah memilih Resource Group, Data Integration secara otomatis menguji konektivitas antara kelompok sumber daya dengan sumber data dan tujuan data. Anda juga dapat mengklik Connectivity Check untuk menjalankan pengujian secara manual.
3. Sumber
Konfigurasikan detail tabel sumber untuk sinkronisasi, seperti Schema, Tables, Partition, dan kondisi Data Filtering. Anda dapat mengklik Data Preview untuk melihat data spesifik yang akan disinkronkan.
Pada contoh ini, pilih public untuk Schema dan pilih customer_feedback untuk Table.
4. Pemrosesan data
Pada bagian Pemrosesan data, Anda dapat Enable fitur pemrosesan data. Fitur ini memerlukan sumber daya komputasi tambahan dan meningkatkan beban sumber daya tugas.
Klik Add Node dan pilih AI content processing.
Konfigurasikan pengaturan pemrosesan konten AI.
Parameter utama dijelaskan di bawah ini.
Parameter
Deskripsi
Model Provider
Didukung oleh Layanan Model Bailian Alibaba Cloud.
Model Name
Model yang melakukan pemrosesan data cerdas. Pilih model sesuai kebutuhan. Catatan: Model yang berbeda menghasilkan biaya berbeda. Untuk detailnya, lihat: Biaya Data Agent.
Processing Description
Gunakan bahasa alami untuk mendeskripsikan operasi pada bidang sumber. Referensikan nama bidang dengan format
#{column_name}. Misalnya, dalam kasus ini, masukkanPlease translate '#{feedback_info}' into English.Output Field
Masukkan nama bidang tempat hasil akan disimpan. Jika bidang tersebut belum ada, bidang baru akan dibuat.
CatatanSesuai konfigurasi pada contoh ini, bidang
feedback_infodari tabel sumber diterjemahkan ke dalam bahasa Inggris dan disimpan di bidangfeedback_processed.Klik Output Preview di pojok kanan atas bagian pemrosesan konten AI untuk melihat pratinjau data keluaran akhir.
(Opsional) Anda dapat mengonfigurasi beberapa langkah pemrosesan data yang dijalankan secara berurutan.
Di bawah daftar pemrosesan data, klik tombol + untuk menambahkan langkah pemrosesan data baru.
5. Tujuan
Konfigurasikan informasi tabel tujuan, seperti Schema, Table Name, dan Partition.
Anda dapat mengklik Generate Target Table Schema untuk membuat tabel tujuan secara cepat.
Jika tabel untuk menerima data sudah ada di tujuan, Anda dapat memilihnya.
Konfigurasikan Write Mode dan Write Conflict Policy.
Pilih
publicuntuk Schema dancustomer_feedback_after_translateuntuk Table. Atur write mode keSQL(INSERT INTO), write conflict strategy keIgnore, dan Clear Hologres table before synchronization keDo not clear destination table (false). Atur maximum connections ke9.Konfigurasikan apakah akan menghapus data yang sudah ada di tabel Hologres sebelum sinkronisasi.
(Opsional) Konfigurasikan Maximum Connections.
Pengaturan Maximum Connections hanya berlaku ketika write mode adalah
SQL(INSERT INTO). Saat Anda menjalankan tugas, pastikan instans Hologres memiliki cukup koneksi idle. Satu tugas dapat menggunakan hingga sembilan koneksi.
6. Pemetaan bidang tujuan
Setelah Anda mengonfigurasi sumber data, pemrosesan data, dan tujuan, bagian ini menampilkan pemetaan bidang. Secara default, Data Integration memetakan bidang berdasarkan nama dan posisi. Untuk menyesuaikan pemetaan (misalnya, memetakan feedback_processed ke translate_feedback), klik bidang yang sesuai untuk menghubungkannya.
Pada contoh ini, selain pemetaan nama yang sama untuk bidang tabel sumber yang sudah ada (id, device, feedback_info, dan pt), Anda juga harus memetakan secara manual bidang feedback_processed, yang menyimpan hasil terjemahan, ke bidang translate_feedback di tabel tujuan.
Langkah 3: Debug tugas
Di panel kanan editor tugas, klik Run Configuration. Konfigurasikan Resource Group dan Script Parameters terkait untuk debugging node ini.
Di bilah alat di bagian atas node, klik Save lalu klik Running. Tunggu hingga tugas selesai, dan periksa apakah eksekusi berhasil. Anda dapat membuka database tujuan untuk memverifikasi bahwa data tabel sesuai harapan.
Langkah 4: Konfigurasikan penjadwalan
Untuk menjalankan node sinkronisasi batch sesuai jadwal, konfigurasikan Scheduling Policy di panel Scheduling Settings di sebelah kanan. Untuk informasi lebih lanjut, lihat Konfigurasikan properti penjadwalan node.
Langkah 5: Publikasikan node
Klik ikon Publish di bilah alat node untuk memulai proses publikasi dan memublikasikan tugas ke lingkungan produksi. Tugas hanya akan dijalankan sesuai jadwal setelah dipublikasikan.
Langkah berikutnya: O&M Tugas
Setelah Anda mempublikasikan node, Anda dapat mengklik Backfill Data atau Perform O&M di kotak dialog publikasi.
Backfill Data: Opsi ini hanya mendukung pengisian ulang data untuk node saat ini. Untuk operasi pengisian ulang data yang lebih kompleks, buka Pusat Operasi. Untuk informasi lebih lanjut, lihat Kelola instans pengisian ulang data.
Perform O&M: Setelah Anda mempublikasikan tugas, Pusat Operasi akan mengelolanya secara otomatis. Di Pusat Operasi, Anda dapat melihat status eksekusi tugas atau memicunya secara manual. Untuk informasi lebih lanjut, lihat Pusat Operasi.