

Setelah mempertimbangkan dengan cermat, kami memutuskan untuk menghentikan Amazon Kinesis Data Analytics untuk aplikasi SQL:

1. Mulai **1 September 2025,** kami tidak akan memberikan perbaikan bug untuk Amazon Kinesis Data Analytics untuk aplikasi SQL karena kami akan memiliki dukungan terbatas untuk itu, mengingat penghentian yang akan datang.

2. Mulai **15 Oktober 2025,** Anda tidak akan dapat membuat Kinesis Data Analytics baru untuk aplikasi SQL.

3. Kami akan menghapus aplikasi Anda mulai **27 Januari 2026**. Anda tidak akan dapat memulai atau mengoperasikan Amazon Kinesis Data Analytics untuk aplikasi SQL. Support tidak akan lagi tersedia untuk Amazon Kinesis Data Analytics untuk SQL sejak saat itu. Untuk informasi selengkapnya, lihat [Amazon Kinesis Data Analytics untuk penghentian Aplikasi SQL](discontinuation.md).

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

# Langkah 1: Siapkan Data
<a name="app-anomaly-with-ex-prepare"></a>

Sebelum Anda membuat aplikasi Amazon Kinesis Data Analytics untuk [contoh](app-anomaly-detection-with-explanation.md), Anda membuat Kinesis data stream untuk digunakan sebagai sumber streaming untuk aplikasi Anda. Anda juga menjalankan kode Python untuk menulis simulasi data tekanan darah ke aliran. 

**Topics**
+ [Langkah 1.1: Buat Kinesis Data Stream](#app-anomaly-create-two-streams)
+ [Langkah 1.2: Tulis Catatan Sampel ke Aliran Input](#app-anomaly-write-sample-records-inputstream)

## Langkah 1.1: Buat Kinesis Data Stream
<a name="app-anomaly-create-two-streams"></a>

Dalam bagian ini, Anda membuat Kinesis data stream bernama `ExampleInputStream`. Anda dapat membuat aliran data ini menggunakan Konsol Manajemen AWS atau AWS CLI.
+ Untuk menggunakan konsol:

  1. [Masuk ke Konsol Manajemen AWS dan buka konsol Kinesis di /kinesis. https://console.aws.amazon.com](https://console.aws.amazon.com/kinesis)

  1. Pilih **Data Streams** (Aliran Data) di panel navigasi. Selanjutnya pilih **Create Kinesis stream** (Buat Kinesis stream).

  1. Untuk nama, masukkan **ExampleInputStream**. Untuk jumlah serpihan, masukkan **1**.
+ Atau, untuk menggunakan AWS CLI untuk membuat aliran data, jalankan perintah berikut:

  ```
  $ aws kinesis create-stream --stream-name ExampleInputStream --shard-count 1
  ```

## Langkah 1.2: Tulis Catatan Sampel ke Aliran Input
<a name="app-anomaly-write-sample-records-inputstream"></a>

Dalam langkah ini, Anda menjalankan kode Python untuk terus membuat catatan sampel dan menulisnya ke aliran data yang Anda buat. 

1. Instal Python dan pip.

   Untuk informasi tentang menginstal Python, lihat [Python](https://www.python.org/). 

   Anda dapat menginstal dependensi menggunakan pip. Untuk informasi tentang menginstal pip, lihat [Penginstalan](https://pip.pypa.io/en/stable/installing/) di dokumentasi pip.

1. Jalankan kode Phyton berikut. Anda dapat mengubah Wilayah ke salah satu yang ingin Anda gunakan untuk contoh ini. Perintah `put-record` dalam kode menulis catatan JSON ke aliran.

   ```
    
   from enum import Enum
   import json
   import random
   import boto3
   
   STREAM_NAME = "ExampleInputStream"
   
   
   class PressureType(Enum):
       low = "LOW"
       normal = "NORMAL"
       high = "HIGH"
   
   
   def get_blood_pressure(pressure_type):
       pressure = {"BloodPressureLevel": pressure_type.value}
       if pressure_type == PressureType.low:
           pressure["Systolic"] = random.randint(50, 80)
           pressure["Diastolic"] = random.randint(30, 50)
       elif pressure_type == PressureType.normal:
           pressure["Systolic"] = random.randint(90, 120)
           pressure["Diastolic"] = random.randint(60, 80)
       elif pressure_type == PressureType.high:
           pressure["Systolic"] = random.randint(130, 200)
           pressure["Diastolic"] = random.randint(90, 150)
       else:
           raise TypeError
       return pressure
   
   
   def generate(stream_name, kinesis_client):
       while True:
           rnd = random.random()
           pressure_type = (
               PressureType.low
               if rnd < 0.005
               else PressureType.high
               if rnd > 0.995
               else PressureType.normal
           )
           blood_pressure = get_blood_pressure(pressure_type)
           print(blood_pressure)
           kinesis_client.put_record(
               StreamName=stream_name,
               Data=json.dumps(blood_pressure),
               PartitionKey="partitionkey",
           )
   
   
   if __name__ == "__main__":
       generate(STREAM_NAME, boto3.client("kinesis"))
   ```

**Langkah Selanjutnya**  
[Langkah 2: Buat Aplikasi Analitik](app-anom-with-exp-create-app.md)