Gunakan API layanan antrian PAI-EAS dan EASCMD untuk inferensi async - Platform for AI

Topik ini menjelaskan cara mengakses layanan antrian menggunakan API HTTP, SDK, atau eascmd.

Akses layanan antrian melalui API

Setelah Anda men-deploy layanan inferensi asinkron, sistem secara otomatis menghasilkan titik akhir (endpoint) untuk antrian input dan antrian output (juga disebut antrian sink). Tabel berikut menjelaskan format endpoint HTTP tersebut.

Jenis endpoint	Format endpoint	Contoh
Endpoint antrian input	`{domain}/api/predict/{service_name}`	`xxx.cn-shanghai.pai-eas.aliyuncs.com/api/predict/{service_name}`
Endpoint antrian output	`{domain}/api/predict/{service_name}/sink`	`xxx.cn-shanghai.pai-eas.aliyuncs.com/api/predict/{service_name}/sink`

Pada tab Inference Service, klik nama layanan target untuk membuka halaman Overview. Di bagian Basic Information, klik View Endpoint Information untuk menemukan endpoint antrian input, endpoint antrian output, dan token.

Kirim data ke antrian

Gunakan perintah curl untuk mengirim permintaan inferensi sinkron atau asinkron ke antrian input.

$ curl -v http://182848887922****.cn-shanghai.pai-eas.aliyuncs.com/api/predict/qservice -H 'Authorization: YmE3NDkyMzdiMzNmMGM3ZmE4ZmNjZDk0M2NiMDA3OTZmNzc1MT****==' -d '[{}]'

Contoh berikut menunjukkan responsnya.

> POST /api/predict/qservice HTTP/1.1
> Host: 182848887922****.cn-shanghai.pai-eas.aliyuncs.com
> Authorization: YmE3NDkyMzdiMzNmMGM3ZmE4ZmNjZDk0M2NiMDA3OTZmNzc1MT****==
>
< HTTP/1.1 200 OK
< Content-Length: 19
< X-Eas-Queueservice-Request-Id: 4e034bnvb-e783-4272-9333-68x6a1v8dc6x
<
1033

Respons tersebut berisi informasi berikut:

Header respons X-Eas-Queueservice-Request-Id berisi ID permintaan, 4e034bnvb-e783-4272-9333-68x6a1v8dc6x, yang dapat Anda gunakan untuk mengkueri data.
Badan respons berisi indeks permintaan dalam antrian, 1033, yang dapat Anda gunakan untuk mengkueri data.

Kirim data prioritas

Layanan antrian biasanya memproses data dalam urutan First-In, First-Out (FIFO). Namun, untuk memproses data tertentu dengan prioritas lebih tinggi, tambahkan parameter kueri _priority_=1 ke permintaan Anda.

$ curl -v http://182848887922****.cn-shanghai.pai-eas.aliyuncs.com/api/predict/qservice?_priority_=1 -H 'Authorization: YmE3NDkyMzdiMzNmMGM3ZmE4ZmNjZDk0M2NiMDA3OTZmNzc1MT****==' -d '[{}]'

Contoh berikut menunjukkan responsnya.

> POST /api/predict/qservice?_priority_=1 HTTP/1.1
> Host: 182848887922****.cn-shanghai.pai-eas.aliyuncs.com
> Authorization: YmE3NDkyMzdiMzNmMGM3ZmE4ZmNjZDk0M2NiMDA3OTZmNzc1MT****==
>
< HTTP/1.1 200 OK
< Content-Length: 19
< X-Eas-Queueservice-Request-Id: 4033eb55-e783-4922-9777-68d6a1383c76
<
1034

Setelah data prioritas ditulis ke antrian, layanan akan mendorongnya ke subscriber untuk diproses sebelum data prioritas standar.

Detail layanan antrian

Jika Anda menambahkan parameter _attrs_=true ke permintaan, responsnya akan menyertakan informasi detail tentang antrian.

$ curl -v -H 'Authorization: YmE3NDkyMzdiMzNmMGM3ZmE4ZmNjZDk0M2NiMDA3OTZmNzc1MT****==' http://182848887922****.cn-shanghai.pai-eas.aliyuncs.com/api/predict/qservice?_attrs_=true

Contoh berikut menunjukkan responsnya.

> GET /api/predict/qservice?_attrs_=true HTTP/1.1
> Host: 182848887922****.cn-shanghai.pai-eas.aliyuncs.com
> Authorization: YmE3NDkyMzdiMzNmMGM3ZmE4ZmNjZDk0M2NiMDA3OTZmNzc1MT****==
>
< HTTP/1.1 200 OK
< Content-Length: 320
<
{"consumers.stats.total":"0","consumers.status.total":"0","meta.header.group":"X-EAS-QueueService-Gid","meta.header.priority":"X-EAS-QueueService-Priority","meta.header.user":"X-EAS-QueueService-Uid","stream.maxPayloadBytes":"524288","meta.name":"pmml_test","meta.state":"Normal","stream.approxMaxLength":"4095","stream.firstEntry":"0","stream.lastEntry":"0","stream.length":"1"}

Respons dikembalikan dalam format JSON. Tabel berikut menjelaskan bidang utamanya.

Parameter	Deskripsi
stream.maxPayloadBytes	Ukuran maksimum, dalam byte, dari item data yang diterima oleh antrian.
stream.approxMaxLength	Jumlah maksimum item data yang dapat disimpan dalam antrian.
stream.firstEntry	Indeks item data pertama dalam antrian.
stream.lastEntry	Indeks item data terakhir dalam antrian.
stream.length	Jumlah item data saat ini dalam antrian.
meta.state	Status saat ini dari antrian.

Anda juga dapat membuka halaman Elastic Algorithm Service (EAS), klik nama layanan inferensi asinkron untuk membuka halaman Overview, lalu beralih ke tab Asynchronous Queue untuk melihat informasi antrian.

Kueri data

Kueri hasil berdasarkan kondisi

Saat menggunakan satu layanan antrian, Anda dapat mengkueri data dari antrian input berdasarkan indeks atau ID permintaan.

# Kueri data berdasarkan indeks.
$ curl -v -H 'Authorization: YmE3NDkyMzdiMzNmMGM3ZmE4ZmNjZDk0M2NiMDA3OTZmNzc1MT****==' http://182848887922****.cn-shanghai.pai-eas.aliyuncs.com/api/predict/qservice?_index_=1022
# Kueri data berdasarkan ID permintaan.
$ curl -v -H 'Authorization: YmE3NDkyMzdiMzNmMGM3ZmE4ZmNjZDk0M2NiMDA3OTZmNzc1MT****==' http://182848887922****.cn-shanghai.pai-eas.aliyuncs.com/api/predict/qservice?requestId=87633037-39a4-40bf-8405-14f8e0c31896

Contoh berikut menunjukkan responsnya.

> GET /api/predict/qservice?_index_=1022&_auto_delete_=false HTTP/1.1
> Host: 182848887922****.cn-shanghai.pai-eas.aliyuncs.com
> Authorization: YmE3NDkyMzdiMzNmMGM3ZmE4ZmNjZDk0M2NiMDA3OTZmNzc1MT****==
>
< HTTP/1.1 200 OK
< Content-Length: 4
< Content-Type: text/plain; charset=utf-8
<
[{}]

Anda dapat mengonfigurasi parameter berikut untuk mengkueri hasil inferensi. Tabel berikut menjelaskan parameter tersebut.

Parameter	Tipe	Deskripsi
_index_	INT	Indeks awal data yang akan dikueri. Nilai default adalah 0, yang menunjukkan bahwa kueri dimulai dari item data pertama dalam antrian. Semakin dekat indeks ini dengan data yang Anda kueri, semakin efisien kuerinya.
_length_	INT	Jumlah item data yang akan dikueri. Nilai default adalah 1, yang menunjukkan hanya satu item data yang dikueri.
_auto_delete_	BOOL	Menentukan apakah data yang dikueri akan dihapus dari antrian. Nilai default adalah TRUE, yang menunjukkan bahwa layanan secara otomatis menghapus item data yang dikueri dari antrian setelah kueri selesai.
_timeout_	STRING	Periode timeout. Nilai default adalah 0, yang menunjukkan bahwa sistem segera mengembalikan kode status 204 jika tidak ada data yang memenuhi kondisi dalam antrian. Jika tidak, sistem akan menunggu selama periode yang ditentukan. Jika data yang memenuhi kondisi muncul dalam antrian dalam periode timeout, sistem akan mengembalikan data tersebut. Contoh nilai: 1s (1 detik) dan 1m (1 menit).
requestId	STRING	`requestId` adalah tag bawaan yang digunakan untuk mengkueri data. Catatan Saat Anda menggunakan layanan inferensi asinkron, framework EAS membaca data permintaan dari antrian input, memprosesnya, dan menulis hasilnya ke antrian output. Framework menggunakan tag `requestId` untuk mengaitkan data input dengan data output yang sesuai. Oleh karena itu, Anda dapat menggunakan `requestId` dari permintaan awal untuk mengkueri hasil inferensi dari antrian output.

Kueri hasil inferensi asinkron

Saat Anda memasangkan layanan antrian dengan layanan inferensi, layanan inferensi secara otomatis membaca data permintaan dari antrian input, melakukan perhitungan inferensi, dan menulis hasilnya ke antrian output (sink). Gunakan kode berikut untuk mengkueri data dari antrian output menggunakan ID permintaan seperti 0337f7a1-a6f6-49a6-8ad7-ff2fd12b****.

$ curl -v -H 'Authorization: YmE3NDkyMzdiMzNmMGM3ZmE4ZmNjZDk0M2NiMDA3OTZmNzc1MT****==' http://182848887922****.cn-shanghai.pai-eas.aliyuncs.com/api/predict/qservice/sink?requestId=0337f7a1-a6f6-49a6-8ad7-ff2fd12bbe2d

Contoh berikut menunjukkan responsnya.

> GET /api/predict/qservice/sink?requestId=0337f7a1-a6f6-49a6-8ad7-ff2fd12b**** HTTP/1.1
> Host: 182848887922****.cn-shanghai.pai-eas.aliyuncs.com
> Authorization: YmE3NDkyMzdiMzNmMGM3ZmE4ZmNjZDk0M2NiMDA3OTZmNzc1MT****==
>
< HTTP/1.1 200 OK
< Content-Length: 53
< Content-Type: text/plain; charset=utf-8
<
[{"p_0":0.5224580736905329,"p_1":0.4775419263094671}]

Pembersihan data

Saat Anda tidak lagi memerlukan data tertentu dalam antrian, Anda dapat menggunakan API untuk menghapusnya. Anda dapat menghapus data dengan dua cara: menghapus satu item data (delete) dan menghapus data hingga titik tertentu (truncate).

Hapus satu item data

# Hapus data berdasarkan indeks.
$ curl -XDELETE -v -H 'Authorization: YmE3NDkyMzdiMzNmMGM3ZmE4ZmNjZDk0M2NiMDA3OTZmNzc1MT****==' http://182848887922****.cn-shanghai.pai-eas.aliyuncs.com/api/predict/qservice?_index_=1022

Contoh berikut menunjukkan responsnya.

> DELETE /api/predict/qservice?_index_=1022 HTTP/1.1
> Host: 182848887922****.cn-shanghai.pai-eas.aliyuncs.com
> Authorization: YmE3NDkyMzdiMzNmMGM3ZmE4ZmNjZDk0M2NiMDA3OTZmNzc1MT****==
>
< HTTP/1.1 200 OK
< Content-Length: 4
< Content-Type: text/plain; charset=utf-8
<
OK

Anda dapat mengonfigurasi parameter berikut untuk menghapus hasil inferensi. Tabel berikut menjelaskan parameter tersebut.

Parameter	Tipe	Deskripsi
_index_	INT	Indeks item data yang akan dihapus.

Hapus data secara batch

# Hapus data berdasarkan indeks.
$ curl -XDELETE -v -H 'Authorization: YmE3NDkyMzdiMzNmMGM3ZmE4ZmNjZDk0M2NiMDA3OTZmNzc1MT****==' http://182848887922****.cn-shanghai.pai-eas.aliyuncs.com/api/predict/qservice?_index_=1023&_trunc_=true

Contoh berikut menunjukkan responsnya.

> DELETE /api/predict/qservice?_index_=1023&_trunc_=true HTTP/1.1
> Host: 182848887922****.cn-shanghai.pai-eas.aliyuncs.com
> Authorization: YmE3NDkyMzdiMzNmMGM3ZmE4ZmNjZDk0M2NiMDA3OTZmNzc1MT****==
>
< HTTP/1.1 200 OK
< Content-Length: 4
< Content-Type: text/plain; charset=utf-8
<
OK

Anda dapat mengonfigurasi parameter berikut untuk menghapus hasil inferensi. Tabel berikut menjelaskan parameter tersebut.

Parameter	Jenis	Deskripsi
_index_	INT	Indeks batas untuk penghapusan data. Layanan akan menghapus item data dengan indeks lebih rendah dari indeks ini.
_trunc_	BOOL	Parameter ini harus diatur ke `true` untuk penghapusan batch. Jika tidak, layanan akan melakukan penghapusan satu item saja.

Langganan dan dorong layanan antrian

Dalam skenario inferensi asinkron, selain menggunakan kueri blocking, Anda dapat berlangganan layanan untuk menerima hasil inferensi. Layanan antrian menyediakan antarmuka langganan (watch) bagi klien untuk mengambil hasil inferensi. Layanan antrian mengontrol ukuran jendela langganan berdasarkan konkurensi (worker_threads) yang dikonfigurasi untuk instans layanan inferensi saat ini. Saat data baru ditulis ke antrian, layanan antrian secara otomatis mendorong data tersebut ke klien yang berlangganan.

Fitur ini mengenkapsulasi implementasi QueueClient dalam SDK dengan menggunakan protokol WebSocket untuk membuat koneksi persisten guna notifikasi dorong. Contoh berikut menunjukkan cara menggunakan QueueClient dalam SDK Python untuk berlangganan data dalam antrian pada skenario pemrosesan aliran video dan audio khas.

Catatan

Layanan inferensi tidak wajib. Anda juga dapat menggunakan SDK untuk berlangganan antrian input layanan antrian dalam layanan kustom. Anda dapat menulis hasil output ke antrian pesan pihak ketiga atau penyimpanan target lainnya, seperti menulis gambar ke OSS.

Instal EAS Python SDK.
```
pip install eas_prediction --user
```

Gunakan metode put() dari QueueClient untuk mengirim data ke antrian input dan metode watch() untuk berlangganan data dari antrian output. Dalam skenario produksi, thread yang berbeda biasanya menangani pengiriman dan langganan data. Namun, contoh ini menggunakan satu thread untuk kedua operasi: pertama mengirim data menggunakan put(), lalu menerima hasilnya menggunakan watch().

#!/usr/bin/env python
from eas_prediction import QueueClient
# Buat objek antrian input untuk menulis data input.
input_queue = QueueClient('182848887922****.cn-shanghai.pai-eas.aliyuncs.com', 'qservice')
# Untuk menyesuaikan user dan group, Anda dapat menentukannya menggunakan uid dan gid. Contoh:
# input_queue = QueueClient('182848887922****.cn-shanghai.pai-eas.aliyuncs.com', 'qservice', uid='your_user_id', gid='your_group_id')
input_queue.set_token('YmE3NDkyMzdiMzNmMGM3ZmE4ZmNjZDk0M2NiMDA3OTZmNzc1MT****==')
input_queue.init()

# Buat objek antrian output untuk berlangganan dan membaca data output.
sink_queue = QueueClient('182848887922****.cn-shanghai.pai-eas.aliyuncs.com', 'qservice/sink')
sink_queue.set_token('YmE3NDkyMzdiMzNmMGM3ZmE4ZmNjZDk0M2NiMDA3OTZmNzc1MT****==')
sink_queue.init()

# Dorong 10 item data ke antrian input.
for x in range(10):
    index, request_id = input_queue.put('[{}]')
    print(index, request_id)

    # Lihat detail antrian input.
    attrs = input_queue.attributes()
    print(attrs)

# Pantau data dari antrian output dengan jendela 5.
i = 0
watcher = sink_queue.watch(0, 5, auto_commit=False)
for x in watcher.run():
    print(x.data.decode('utf-8'))

    # Lakukan commit secara manual setelah item data diterima dan diproses.
    sink_queue.commit(x.index)
    i += 1
    if i == 10:
        break
# Tutup objek watcher. Setiap instans klien hanya dapat memiliki satu objek watcher. Jika objek watcher tidak ditutup, kesalahan akan terjadi pada eksekusi berikutnya.
watcher.close()

Akses layanan antrian melalui eascmd

eascmd mengenkapsulasi API lengkap layanan antrian. Anda dapat menggunakan subperintah eascmd stream untuk mengoperasikan dan men-debug layanan antrian dengan cepat.

Unduh eascmd

Pastikan versi eascmd Anda lebih baru dari 2.6.0. Untuk informasi lebih lanjut tentang cara mengunduh, memperbarui, dan mengonfigurasi klien command-line eascmd, lihat Unduh dan autentikasi klien.

Konfigurasi akses eascmd

Jalankan perintah eascmd stream config untuk mengonfigurasi layanan antrian yang ingin Anda akses. Contoh:

eascmd stream config --url=http://182848887922****.cn-shanghai.pai-eas.aliyuncs.com/api/predict/qservice --token=YmE3NDkyMzdiMzNmMGM3ZmE4ZmNjZDk0M2NiMDA3OTZmNzc1MT****==

Setelah konfigurasi selesai, eascmd menggunakan default_group dan default_user sebagai group_id dan user_id default. Untuk informasi lebih lanjut tentang group dan user, lihat Langganan dan dorong layanan antrian. Untuk menggunakan group_id atau user_id yang berbeda, tentukan dengan parameter --group dan --user. Anda dapat mengganti semua parameter dalam stream config dengan perintah baca dan tulis berikutnya.

Detail antrian

Jalankan perintah info untuk melihat informasi antrian. Contoh:

eascmd stream info

Contoh berikut menunjukkan responsnya.

[OK] Attributes: 
consumers.list.[0] : Id: imageasync.imageasync-35d72370-5f576f7c8d-2mdb4, Index: 0, Pending: 0, Status: Running, Idle: 19.997s, Window: 5, Slots: 5, AutoCommit: false
consumers.stats.total : 1
consumers.status.total : 1
groups.list.[0] : Id: imageasync, Index: 0, Pending: 0, Delivered: 1, Consumers: 1
meta.header.group : X-EAS-QueueService-Gid
meta.header.priority : X-EAS-QueueService-Priority
meta.header.user : X-EAS-QueueService-Uid
meta.maxPayloadBytes : 8192
meta.name : imageasync-queue-38895e88
meta.state : Normal
stream.approxMaxLength : 230399
stream.firstEntry : 0
stream.lastEntry : 0
stream.length : 0

Untuk informasi lebih lanjut tentang parameter dalam respons, lihat Akses layanan antrian menggunakan API. Anda dapat menggunakan perintah info untuk mengamati properti antrian dan menguji konektivitas ke layanan antrian.

Kirim data ke antrian

Jalankan perintah put untuk mengirim data ke antrian. Contoh:

eascmd stream put -d "10s"

Contoh berikut menunjukkan responsnya.

[OK] 1
[INFO] Put data done.
Total time cost: 401.892141ms
Total size: 3.00 B
Total: 1, success: 1, failed: 0

Anda juga dapat menggunakan parameter -f untuk mengirim semua data dari file ke antrian. Contoh:

eascmd stream put -f test.data

Contoh berikut menunjukkan responsnya.

[INFO] Opening data file: test.data
[OK] 2
[OK] 3
[OK] 4
[OK] 5
[OK] 6
[OK] 7
[OK] 8
[OK] 9
[OK] 10
[OK] 11
[OK] 12
[OK] 13
....

Anda kemudian dapat menjalankan perintah info untuk mengamati status antrian.

Kueri data

Jalankan perintah get untuk mengkueri data dari antrian input. Contoh:

eascmd stream get -l10 --timeout=3s

Contoh berikut menunjukkan responsnya.

[OK] [0 - 1] tags[Header:Content-Type=text/plain; charset=utf-8 requestId=e47b76e2-2648-40fe-9197-a268015cbd1f ts@source=1685802680575] data1
[OK] [1 - 2] tags[Header:Content-Type=text/plain; charset=utf-8 requestId=51d13952-6ba3-4d52-b548-e58837675c7a ts@source=1685807531686] data2
[OK] [2 - 3] tags[Header:Content-Type=text/plain; charset=utf-8 requestId=ef6940e3-159c-45f3-a96d-bc0acd71275f ts@source=1685807531701] OK
[OK] [3 - 4] tags[Header:Content-Type=text/plain; charset=utf-8 requestId=2a5645b6-9ee5-4026-bdee-fab31e435934 ts@source=1685807531715] data4
[OK] [4 - 5] tags[Header:Content-Type=text/plain; charset=utf-8 requestId=64ba6aaf-49b0-45c7-8d79-6cf6dc1065d0 ts@source=1685807531730] data5
...

Daftar berikut menjelaskan format output, menggunakan item data pertama sebagai contoh:

Kolom pertama [0 - 1] menunjukkan bahwa item data ke-0 yang diterima memiliki indeks 1.
Kolom kedua tags[Header:Content-Type=text/plain; charset=...] menunjukkan tag yang terkait dengan data.
- Tag yang diawali dengan Header sesuai dengan header HTTP dari permintaan input.
- requestId adalah ID permintaan yang dihasilkan secara otomatis dan bawaan.
- ts@source menunjukkan timestamp Unix saat antrian input menerima permintaan Anda. ts@sink menunjukkan timestamp saat antrian output menerima data.
Kolom terakhir menampilkan data yang Anda masukkan.

Penting

Jika Anda memiliki instans layanan inferensi yang dipasangkan, instans tersebut mungkin mengonsumsi data yang Anda kirimkan ke antrian. Dalam kasus ini, Anda harus mengkueri data dari antrian output dengan menambahkan parameter -k ke perintah.

Anda juga dapat menambahkan kondisi kueri menggunakan parameter --tags. Misalnya, untuk mengkueri data berdasarkan requestId, jalankan perintah berikut:

eascmd stream get --tags requestId=ef6940e3-159c-45f3-a96d-bc0acd71275f

Contoh berikut menunjukkan responsnya.

[OK] [0 - 3] tags[Header:Content-Type=text/plain; charset=utf-8 requestId=ef6940e3-159c-45f3-a96d-bc0acd71275f ts@source=1685807531701] OK

Hapus data

Anda dapat menjalankan perintah delete dan trunc untuk menghapus satu item data atau data secara batch.

Hapus satu item data:

 eascmd stream delete 3

Setelah Anda mengonfirmasi penghapusan, respons berikut dikembalikan:

Deleting index(es):
3 [y/N]y
[OK] deleted

Hapus data secara batch:

eascmd stream trunc 4

Setelah Anda mengonfirmasi penghapusan, respons berikut dikembalikan:

trunc stream from index: 4 [y/N]y
[OK] truncated

Langganan antrian

Jalankan perintah watch untuk berlangganan layanan antrian.

 eascmd stream watch

Contoh berikut menunjukkan responsnya.

[INFO] Start to watch: index: 0, indexOnly: false, autoCommit: false, window: 10
I0604 09:20:45.211243   66197 queue.go:532] watch via websocket
[OK] [0 - 4] tags[Header:Content-Type=text/plain; charset=utf-8 requestId=2a5645b6-9ee5-4026-bdee-fab31e435934 ts@sink=1685807531718 ts@source=1685807531715] data4
commit: 4 ? [Y/n]

Saat Anda memasukkan Y, klien melakukan commit data dan Anda menerima data baru.

[OK] [1 - 5] tags[Header:Content-Type=text/plain; charset=utf-8 requestId=64ba6aaf-49b0-45c7-8d79-6cf6dc1065d0 ts@sink=1685807531733 ts@source=1685807531730] data5
commit: 5 ? [Y/n]

Jika Anda memasukkan n, Anda akan diminta untuk melakukan negative commit.

[OK] [1 - 5] tags[Header:Content-Type=text/plain; charset=utf-8 requestId=64ba6aaf-49b0-45c7-8d79-6cf6dc1065d0 ts@sink=1685807531733 ts@source=1685807531730] data5
commit: 5 ? [Y/n]n
negative: 5 ? [Y/n]y

Untuk informasi lebih lanjut tentang commit dan negative commit, lihat Commit dan Negative.

Jika Anda menggunakan opsi --auto-commit, server secara otomatis melakukan commit data.

 eascmd stream  watch --auto-commit

Contoh berikut menunjukkan responsnya.

[INFO] Start to watch: index: 0, indexOnly: false, autoCommit: true, window: 10
I0604 09:30:08.554542   66408 queue.go:532] watch via websocket
[OK] [0 - 5] tags[Header:Content-Type=text/plain; charset=utf-8 requestId=64ba6aaf-49b0-45c7-8d79-6cf6dc1065d0 ts@sink=1685807531733 ts@source=1685807531730] data5
[OK] [1 - 6] tags[Header:Content-Type=text/plain; charset=utf-8 requestId=5825dd3e-a5e2-4754-a946-96e068d643c8 ts@sink=1685807531771 ts@source=1685807531768] data6
[OK] [2 - 7] tags[Header:Content-Type=text/plain; charset=utf-8 requestId=e7edf9b8-de78-41a0-8d9c-0a4aaf7dcaaf ts@sink=1685807531786 ts@source=1685807531783] data7
[OK] [3 - 8] tags[Header:Content-Type=text/plain; charset=utf-8 requestId=3ddc3481-934a-4408-8d08-11c2c2248ef6 ts@sink=1685807531801 ts@source=1685807531798] data8
[OK] [4 - 9] tags[Header:Content-Type=text/plain; charset=utf-8 requestId=561da95d-b99a-4710-bb82-9402baa21f36 ts@sink=1685807531816 ts@source=1685807531812] data9
....

Opsi dan perintah lainnya

Bagian sebelumnya menjelaskan perintah dan opsi utama untuk eascmd stream. Untuk informasi lebih lanjut tentang fitur lainnya, jalankan perintah eascmd stream help.