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.
# Contoh: Mengekstrak Bagian String (Fungsi SUBSTRING)
Contoh menggunakan fungsi `SUBSTRING` untuk mengubah string di Amazon Kinesis Data Analytics. Fungsi `SUBSTRING` mengekstrak sebagian string sumber yang dimulai dari posisi tertentu. Untuk informasi selengkapnya, lihat [SUBSTRING](https://docs.aws.amazon.com/kinesisanalytics/latest/sqlref/sql-reference-substring.html) di *Amazon Managed Service for Apache Flink* SQL Reference.
Dalam contoh ini, Anda menulis catatan berikut ke Amazon Kinesis data stream.
```
{ "REFERRER" : "http://www.amazon.com" }
{ "REFERRER" : "http://www.amazon.com"}
{ "REFERRER" : "http://www.amazon.com"}
...
```
Anda kemudian membuat aplikasi Kinesis Data Analytics di konsol, menggunakan aliran data Kinesis sebagai sumber streaming. Proses penemuan membaca catatan sampel pada sumber streaming dan menyimpulkan skema dalam aplikasi dengan satu kolom (`REFERRER`), seperti yang ditunjukkan.
![\[Tangkapan layar konsol yang menampilkan skema dalam aplikasi dengan daftar URLs di kolom perujuk.\]](http://docs.aws.amazon.com/id_id/kinesisanalytics/latest/dev/images/referrer-10.png)
Kemudian, Anda menggunakan kode aplikasi dengan fungsi `SUBSTRING` untuk mengurai string URL untuk mengambil nama perusahaan. Kemudian Anda memasukkan data yang dihasilkan ke aliran dalam aplikasi lainnya, seperti yang ditunjukkan di bawah ini:
![\[Tangkapan layar konsol yang menampilkan tab analitik waktu nyata dengan data yang dihasilkan di aliran dalam aplikasi.\]](http://docs.aws.amazon.com/id_id/kinesisanalytics/latest/dev/images/referrer-20.png)
**Topics**
+ [Langkah 1: Buat Kinesis Data Stream](#examples-transforming-strings-substring-1)
+ [Langkah 2: Buat Aplikasi Kinesis Data Analytics](#examples-transforming-strings-substring-2)
## Langkah 1: Buat Kinesis Data Stream
Buat Amazon Kinesis data stream dan isi catatan log sebagai berikut:
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.
1. Pilih **Create Kinesis stream** (Buat Aliran Kinesis), dan buat aliran dengan satu serpihan. Untuk informasi selengkapnya, lihat [Buat Aliran](https://docs.aws.amazon.com/streams/latest/dev/learning-kinesis-module-one-create-stream.html) di *Panduan Developer Amazon Kinesis Data Streams*.
1. Jalankan kode Python berikut untuk mengisi catatan log sampel. Kode sederhana ini terus menulis catatan log yang sama ke aliran.
```
import json
import boto3
STREAM_NAME = "ExampleInputStream"
def get_data():
return {"REFERRER": "http://www.amazon.com"}
def generate(stream_name, kinesis_client):
while True:
data = get_data()
print(data)
kinesis_client.put_record(
StreamName=stream_name, Data=json.dumps(data), PartitionKey="partitionkey"
)
if __name__ == "__main__":
generate(STREAM_NAME, boto3.client("kinesis"))
```
## Langkah 2: Buat Aplikasi Kinesis Data Analytics
Selanjutnya, buat aplikasi Kinesis Data Analytics sebagai berikut:
1. [Buka Layanan Terkelola untuk konsol Apache Flink di https://console.aws.amazon.com /kinesisanalytics.](https://console.aws.amazon.com/kinesisanalytics)
1. Pilih **Create application** (Buat aplikasi), masukkan nama aplikasi, dan pilih **Create application** (Buat aplikasi).
1. Pada halaman detail aplikasi, pilih **Connect data streaming** (Sambungkan data streaming).
1. Di halaman **Sambungkan ke sumber**, lakukan hal berikut:
1. Pilih aliran yang Anda buat di bagian sebelumnya.
1. Pilih opsi untuk membuat IAM role.
1. Pilih **Discover schema** (Temukan skema). Tunggu hingga konsol menampilkan skema yang disimpulkan dan catatan sampel yang digunakan untuk menyimpulkan skema untuk aliran dalam aplikasi yang dibuat. Skema yang disimpulkan hanya memiliki satu kolom.
1. Jangan pilih **Save and continue** (Simpan dan lanjutkan).
1. Di halaman detail aplikasi, pilih **Go to SQL editor** (Buka editor SQL). Untuk memulai aplikasi, pilih **Yes, start application** (Ya, mulai aplikasi) di kotak dialog yang muncul.
1. Di editor SQL, tulis kode aplikasi, dan verifikasi hasilnya sebagai berikut:
1. Salin kode aplikasi berikut dan tempelkan ke editor.
```
-- CREATE OR REPLACE STREAM for cleaned up referrer
CREATE OR REPLACE STREAM "DESTINATION_SQL_STREAM" (
"ingest_time" TIMESTAMP,
"referrer" VARCHAR(32));
CREATE OR REPLACE PUMP "myPUMP" AS
INSERT INTO "DESTINATION_SQL_STREAM"
SELECT STREAM
"APPROXIMATE_ARRIVAL_TIME",
SUBSTRING("referrer", 12, (POSITION('.com' IN "referrer") - POSITION('www.' IN "referrer") - 4))
FROM "SOURCE_SQL_STREAM_001";
```
1. Pilih **Save and run SQL** (Simpan dan jalankan SQL). Di tab **Real-time analytics **(Analitik waktu nyata), Anda dapat melihat semua aliran dalam aplikasi yang dibuat aplikasi dan memverifikasi data.