Pesan saluran - AWS IoT Analytics
ParameterPesan saluran (konsol)Memproses ulang pesan saluran (API)Membatalkan aktivitas pemrosesan ulang saluran

AWS IoT Analytics tidak lagi tersedia untuk pelanggan baru. Pelanggan yang sudah ada AWS IoT Analytics dapat terus menggunakan layanan seperti biasa. Pelajari selengkapnya

Terjemahan disediakan oleh mesin penerjemah. Jika konten terjemahan yang diberikan bertentangan dengan versi bahasa Inggris aslinya, utamakan versi bahasa Inggris.

Pesan saluran

AWS IoT Analyticsmemungkinkan Anda untuk memproses ulang data saluran. Hal ini dapat berguna dalam kasus berikut:

  • Anda ingin memutar ulang data tertelan yang ada daripada memulai dari awal.

  • Anda membuat update ke pipeline dan ingin membawa data yang ada up-to-date dengan perubahan.

  • Anda ingin menyertakan data yang tertelan sebelum Anda membuat perubahan pada opsi penyimpanan yang dikelola pelanggan, izin untuk saluran, atau penyimpanan data.

Parameter

Ketika Anda memproses ulang pesan saluran melalui pipa denganAWS IoT Analytics, Anda harus menentukan informasi berikut:

StartPipelineReprocessing

Mulai memproses ulang pesan saluran melalui pipa.

ChannelMessages

Menentukan satu atau lebih set pesan saluran yang ingin Anda proses ulang.

Jika Anda menggunakanchannelMessagesobjek, Anda tidak harus menentukan nilai untukstartTimedanendTime.

s3Paths

Menentukan objek Amazon Simple Storage Service (Amazon S3) yang mengidentifikasi objek Amazon Simple Storage Service (Amazon S3). Anda harus menggunakan path lengkap untuk kunci.

Contoh jalan:00:00:00/1582940490000_1582940520000_123456789012_mychannel_0_2118.0.json.gz

Jenis: Array string

Batasan anggota Array: 1-100 item.

Kendala panjang: 1-1024 karakter.

endTime

Waktu akhir (eksklusif) dari data saluran yang diproses ulang.

Jika Anda menentukan nilai untukendTimeparameter, Anda tidak harus menggunakanchannelMessagesobjek.

Jenis: Timestamp

startTime

Waktu mulai (inklusif) data pesan mentah yang diproses ulang.

Jika Anda menentukan nilai untukstartTimeparameter, Anda tidak harus menggunakanchannelMessagesobjek.

Jenis: Timestamp

pipelineName

Nama dari alur untuk memulai pemrosesan ulang.

Jenis: String

Kendala panjang: 1-128 karakter.

Pesan saluran (konsol)

Tutorial ini menunjukkan cara memproses ulang data saluran yang disimpan di objek Amazon S3 yang ditentukan dalamAWS IoT Analyticskonsol.

Sebelum memulai, pastikan pesan saluran yang ingin Anda proses ulang disimpan di bucket Amazon S3 yang dikelola pelanggan.

  1. Masuk ke konsol AWS IoT Analytics tersebut.

  2. Di panel navigasi, pilihAlur.

  3. Pilih jalur target Anda.

  4. PilihPesandariTindakan.

  5. PadaPengolahan ulang alurhalaman, pilihObjek S3untukPesan.

    ParameterAWS IoT Analyticskonsol juga menyediakan pilihan berikut:

    • Semua rentang yang tersedia- Memproses ulang semua data yang valid di saluran.

    • 120 hari terakhir- Memproses ulang data yang tiba dalam 120 hari terakhir.

    • 90 hari terakhir- Data yang tiba dalam 90 hari terakhir.

    • 30 hari terakhir- Memproses ulang data yang tiba dalam 30 hari terakhir.

    • Rentang kustom- Memproses ulang data yang tiba dalam rentang waktu yang ditentukan. Anda dapat memilih rentang waktu apa pun.

  6. Masukkan kunci dari Amazon S3 obejct yang menyimpan pesan saluran Anda.

    Untuk menemukan kunci, lakukan hal berikut:

    1. Pergi keKonsol Amazon S3.

    2. Pilih objek Amazon S3 target.

    3. Di bawahProperti, diIkhtisar objekbagian, salin kuncinya.

  7. PilihMulai memproses ulang.

Memproses ulang pesan saluran (API)

Saat Anda menggunakanStartPipelineReprocessingAPI, perhatikan hal berikut:

  • ParameterstartTimedanendTimeparameter menentukan kapan data mentah tertelan, tetapi ini adalah perkiraan kasar. Anda dapat putaran ke jam terdekat. ParameterstartTimeinklusif, tapiendTimebersifat eksklusif.

  • Perintah meluncurkan pemrosesan ulang asynchronously dan kembali segera.

  • Tidak ada jaminan bahwa pesan yang diproses ulang diproses sesuai urutan yang awalnya diterima. Ini kira-kira sama, tapi tidak tepat.

  • Anda dapat membuat hingga 1000StartPipelineReprocessingPermintaan API setiap 24 jam untuk memproses ulang pesan saluran yang sama melalui saluran pipa.

  • Memproses ulang data mentah Anda menimbulkan biaya tambahan.

Untuk informasi selengkapnya, lihatStartPipelinereProcessingAPI, diAWS IoT AnalyticsReferensi API.

Membatalkan aktivitas pemrosesan ulang saluran

Untuk membatalkan aktivitas pemrosesan ulang pipa, gunakanBatalkan PipelInereProcessingAPI atau pilihBatalkan Pengolahan UlangpadaAktivitashalamanAWS IoT Analyticskonsol. Jika Anda membatalkan pemrosesan ulang, data yang tersisa tidak akan diproses ulang. Anda harus memulai permintaan pemrosesan ulang lainnya.

GunakanDescribePipelineAPI untuk memeriksa status pemrosesan ulang. LihatreprocessingSummarieslapangan dalam respon.