Mendapatkan pemberitahuan data terlambat melalui Amazon CloudWatch Events

Saat Anda membuat konten set data menggunakan data dari kerangka waktu tertentu, beberapa data mungkin tidak tiba tepat waktu untuk diproses. Untuk memungkinkan penundaan, Anda dapat menentukandeltaTime offsetQueryFilter saat Anda membuat kumpulan data dengan menerapkanqueryAction (kueri SQL). AWS IoT Analyticsmasih memproses data yang tiba dalam waktu delta, dan konten kumpulan data Anda memiliki jeda waktu. Fitur notifikasi data yang terlambat memungkinkanAWS IoT Analytics untuk mengirim notifikasi melalui Amazon CloudWatch Events saat data tiba setelah waktu delta.

Anda dapat menggunakanAWS IoT Analytics konsol, API, AWS Command Line Interface(AWS CLI), atau AWSSDK untuk menentukan aturan data terlambat untuk kumpulan data.

DalamAWS IoT Analytics API,LateDataRuleConfiguration objek mewakili pengaturan aturan data akhir dari dataset. Objek ini merupakan bagian dariDataset objek yang terkait dengan operasiCreateDataset danUpdateDataset API.

Parameter

Saat Anda membuat aturan data terlambat untuk kumpulan data denganAWS IoT Analytics, Anda harus menentukan informasi berikut:

ruleConfiguration (LateDataRuleConfiguration)

Struktur yang berisi informasi konfigurasi aturan data akhir.

deltaTimeSessionWindowConfiguration

Struktur yang berisi informasi konfigurasi jendela sesi waktu delta.

DeltaTimemenentukan interval waktu. Anda dapat menggunakan DeltaTime untuk membuat isi set data dengan data yang telah tiba di penyimpanan data sejak eksekusi terakhir. Sebagai contohDeltaTime, lihat Membuat set data SQL dengan jendela delta (CLI).

timeoutInMinutes

Interval waktu. Anda dapat menggunakantimeoutInMinutes agarAWS IoT Analytics dapat mengumpulkan notifikasi data terlambat yang telah dihasilkan sejak eksekusi terakhir. AWS IoT Analyticsmengirimkan satu batch pemberitahuan ke CloudWatch Acara sekaligus.

Tipe: Bilangan Bulat

Rentang yang valid: 1———60

ruleName

Nama aturan data akhir.

Jenis: String

penting

Untuk menentukanlateDataRules, kumpulan data harus menggunakanDeltaTime filter.

Konfigurasi aturan data terlambat (konsol)

Prosedur berikut ini menunjukkan cara mengonfigurasi aturan data terlambat dari kumpulan data diAWS IoT Analytics konsol.

Untuk mengkonfigurasi aturan data terlambat

1. Masuk ke konsol AWS IoT Analytics tersebut.

2. Di panel navigasi, pilih Kumpulan data.

3. Di bawah Kumpulan data, pilih kumpulan data target.

4. Di panel navigasi, pilih Detail.

5. Di bagian jendela Delta, pilih Edit.

6. Pada Konfigurasi filter pemilihan data, lakukan hal berikut:

   1. Untuk jendela Pemilihan data, pilih Waktu Delta.

   2. Untuk Offset, masukkan periode waktu, lalu pilih unit.

   3. Untuk ekspresi Timestamp, masukkan ekspresi. Ini bisa berupa nama bidang timestamp atau ekspresi SQL yang dapat mengambil waktu, seperti from_unixtime (time).

      Untuk informasi selengkapnya tentang cara menulis ekspresi timestamp, lihat Tanggal dan Waktu Fungsi dan Operator di Dokumentasi Presto 0.172.

   4. Untuk Pemberitahuan data terlambat, pilih Aktif.

   5. Untuk waktu Delta, masukkan bilangan bulat. Rentang validnya adalah 1-—60.

   6. Pilih Save (Simpan).

   

Konfigurasikan aturan data terlambat (CLI)

DalamAWS IoT Analytics API,LateDataRuleConfiguration objek mewakili pengaturan aturan data akhir dari dataset. Objek ini adalah bagian dariDataset objek yang terkait denganCreateDataset danUpdateDataset. Anda dapat menggunakan API, AWS CLI, atau AWSSDK untuk menentukan aturan data terlambat untuk kumpulan data. Contoh berikut menggunakanAWS CLI.

Untuk membuat kumpulan data Anda dengan aturan data terlambat, jalankan perintah berikut. Perintah mengasumsikan bahwadataset.json file tersebut dalam direktori saat ini.

catatan

Anda dapat menggunakan UpdateDatasetAPI untuk memperbarui kumpulan data yang ada.

aws iotanalytics create-dataset --cli-input-json file://dataset.json

dataset.jsonFile harus berisi berikut:

• Ganti demo_dataset dengan nama set data target.

• Ganti demo_datastore dengan nama penyimpanan data target.

• Ganti from_unixtime (waktu) dengan nama bidang timestamp atau ekspresi SQL yang dapat mengambil waktu.

  Untuk informasi selengkapnya tentang cara menulis ekspresi timestamp, lihat Tanggal dan Waktu Fungsi dan Operator di Dokumentasi Presto 0.172.

• Ganti batas waktu dengan integer antara 1-60.

• Ganti demo_rule dengan nama apapun.

{
    "datasetName": "demo_dataset",
    "actions": [
        {
            "actionName": "myDatasetAction",
            "queryAction": {
                "filters": [
                    {
                        "deltaTime": {
                            "offsetSeconds": -180,
                            "timeExpression": "from_unixtime(time)"
                        }
                    }
                ],
                "sqlQuery": "SELECT * FROM demo_datastore"
            }
        }
    ],
    "retentionPeriod": {
        "unlimited": false,
        "numberOfDays": 90
    },
    "lateDataRules": [
        {
            "ruleConfiguration": {
                "deltaTimeSessionWindowConfiguration": {
                    "timeoutInMinutes": timeout
                }
            },
            "ruleName": "demo_rule"
        }
    ]
}

Berlangganan untuk menerima data notifikasi terlambat

Anda dapat membuat aturan di CloudWatch Acara yang menentukan cara memproses pemberitahuan data terlambat yang dikirimAWS IoT Analytics. Ketika CloudWatch Peristiwa menerima notifikasi, ia memanggil tindakan target yang ditentukan dalam aturan Anda.

Prasyarat untuk membuat aturan CloudWatch Events

Sebelum Anda membuat aturan CloudWatch Events untukAWS IoT Analytics, Anda harus melakukan hal berikut:

• Biasakan diri Anda dengan peristiwa, dan target di CloudWatch Events.

• Buat dan konfigurasikan target yang dipanggil oleh aturan CloudWatch Acara Anda. Aturan dapat memanggil berbagai jenis target, seperti berikut:

  • Amazon Kinesis Streams

  • AWS Lambda fungsi

  • Topik Amazon Simple Notification Service (Amazon SNS)

  • Antrean Amazon Simple Queue Service (Amazon SQS)

  Aturan CloudWatch Peristiwa Anda, dan target terkait harus berada diAWS Wilayah tempat Anda membuatAWS IoT Analytics sumber daya Anda. Untuk informasi selengkapnya, lihat Endpoint dan kuota layanan di bagian Referensi Umum AWS.

Untuk informasi lebih lanjut, lihat Apa yang dimaksud dengan CloudWatch Events? dan Memulai CloudWatch Acara Amazon di Panduan Pengguna CloudWatch Acara Amazon.

Kejadian pemberitahuan data terlambat

Acara untuk pemberitahuan data terlambat menggunakan format berikut.

{
	"version": "0",
	"id": "7f51dfa7-ffef-97a5-c625-abddbac5eadd",
	"detail-type": "IoT Analytics Dataset Lifecycle Notification",
	"source": "aws.iotanalytics",
	"account": "123456789012",
	"time": "2020-05-14T02:38:46Z",
	"region": "us-east-2",
	"resources": ["arn:aws:iotanalytics:us-east-2:123456789012:dataset/demo_dataset"],
	"detail": {
		"event-detail-version": "1.0",
		"dataset-name": "demo_dataset",
		"late-data-rule-name": "demo_rule",
		"version-ids": ["78244852-8737-4650-aa4d-3071a01338fa"],
		"message": null
	}
}

Membuat aturan CloudWatch Acara untuk menerima pemberitahuan data terlambat

Prosedur berikut ini menunjukkan cara membuat aturan yang mengirimkan notifikasi dataAWS IoT Analytics terlambat ke antrean Amazon SQS.

Untuk membuat aturan CloudWatch Peristiwa

1. Masuk ke CloudWatchkonsol Amazon.

2. Di panel navigasi, di dalam Peristiwa, pilih Aturan.

3. Pada halaman Aturan, pilih Buat aturan.

4. Di bawah Sumber Peristiwa, pilih Pola Peristiwa.

5. Di Bangun pola peristiwa untuk mencocokkan peristiwa berdasarkan layanan bagian, lakukan hal berikut:

   1. Untuk Nama Layanan, pilih IoT Analytics

   2. Untuk Jenis Acara, pilih Pemberitahuan Siklus Hidup Set Data IoT Analytics.

   3. Pilih Nama kumpulan data spesifik, lalu masukkan nama kumpulan data target.

6. Di bawah Target, pilih Tambahkan target*.

7. Pilih antrian SQS, dan kemudian lakukan hal berikut:

   1. Untuk Antrian*, pilih antrian target.

8. Pilih Konfigurasikan detail.

9. Pada Langkah 2: Konfigurasikan halaman detail aturan, masukkan nama dan deskripsi.

10. Pilih Buat aturan.