inferensi asinkron, layanan antrian - Platform For AI

Topik ini menjelaskan cara mengakses layanan antrian dengan memanggil operasi API, menggunakan SDK, atau klien EASCMD.

Akses layanan antrian dengan memanggil operasi API

Setelah menerapkan layanan inferensi asinkron, dua jenis alamat secara otomatis dibuat untuk antrian input dan output (antrian sink). Tabel berikut menyediakan contoh titik akhir HTTP.

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

Pada tab Elastic Algorithm Service (EAS)El, klik nama layanan target untuk membuka halaman Overview. Di bagian Basic Information, klik View Endpoint Information untuk mengambil alamat antrian input, alamat antrian output, dan Token.

Kirim data ke layanan antrian

Gunakan perintah curl untuk mengirim permintaan sinkron atau permintaan inferensi asinkron ke layanan antrian input. Contoh kode:

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

Keluaran berikut dikembalikan:

> 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

Dalam respons sebelumnya:

Nilai 4e034bnvb-e783-4272-9333-68x6a1v8dc6x dari X-Eas-Queueservice-Request-Id dalam header respons adalah ID permintaan. Anda dapat menggunakan ID permintaan untuk menanyakan data.
Nilai 1033 dari Index dalam badan respons adalah indeks permintaan dalam antrian. Anda dapat menggunakan indeks untuk menanyakan data dalam antrian.

Kirim data prioritas

Data didorong ke layanan antrian dalam urutan masuk-pertama-keluar-pertama (FIFO). Namun, dalam banyak skenario, data tertentu harus didorong dan diproses terlebih dahulu. Layanan antrian mendukung pendorongan data berdasarkan prioritas. Anda dapat menambahkan parameter _priority_=1 untuk mendorong data prioritas ke layanan antrian.

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

Keluaran berikut dikembalikan:

> 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, data tersebut didorong ke subscriber sebagai prioritas.

Lihat detail layanan antrian

Jika Anda menambahkan parameter _attrs_=true saat mengirim permintaan ke layanan antrian, detail antrian akan dikembalikan dalam respons. Contoh kode:

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

Keluaran berikut dikembalikan:

> 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"}

Konten yang dikembalikan dalam format JSON. Tabel berikut menjelaskan bidang-bidang tersebut.

Bidang	Deskripsi
stream.maxPayloadBytes	Ukuran maksimum setiap entri data dalam antrian. Satuan: byte.
stream.approxMaxLength	Jumlah maksimum entri data yang dapat disimpan dalam antrian.
stream.firstEntry	Indeks entri data pertama dalam antrian.
stream.lastEntry	Indeks entri data terakhir dalam antrian.
stream.length	Jumlah entri data yang disimpan dalam antrian.
meta.state	Status antrian.

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

Kueri data

Tanyakan Data Berdasarkan Kondisi

Jika Anda hanya menggunakan satu layanan antrian, Anda dapat menggunakan indeks atau ID permintaan untuk mendapatkan data dari antrian input. Contoh kode:

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

Keluaran berikut dikembalikan:

> 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 yang diperlukan untuk menanyakan hasil inferensi. Tabel berikut menjelaskan parameter-parameter tersebut.

Parameter	Tipe	Deskripsi
_index_	INT	Indeks awal data yang ingin Anda tanyakan. Nilai default adalah 0, yang menentukan bahwa penanyaan dimulai dari entri data pertama. Semakin dekat indeks dengan data yang ditanyakan, semakin tinggi efisiensi penanyaan.
_length_	INT	Jumlah entri data yang ingin Anda tanyakan. Nilai default adalah 1, yang menentukan bahwa hanya satu entri data yang ditanyakan.
_auto_delete_	BOOL	Menentukan apakah akan menghapus entri data yang ditanyakan dari antrian. Nilai default: TRUE. Nilai ini menentukan bahwa entri data yang ditanyakan secara otomatis dihapus dari antrian setelah penanyaan selesai.
_timeout_	STRING	Periode timeout. Nilai default adalah 0, yang menentukan bahwa kode status 204 segera dikembalikan jika tidak ada data yang memenuhi kondisi penanyaan. Jika tidak, permintaan menunggu selama waktu tertentu. Jika data yang memenuhi kondisi penanyaan ada dalam antrian dalam periode timeout, data tersebut dikembalikan. Contoh: 1s (1 detik), 1m (1 menit).
requestId	STRING	requestId adalah tag bawaan yang dapat digunakan sebagai kondisi penanyaan. Catatan Saat Anda memanggil layanan inferensi secara asinkron, antrian input mengembalikan permintaan. Kerangka layanan Elastic Algorithm Service (EAS) mendapatkan, memproses, dan menulis data ke antrian output. Kerangka layanan menggunakan tag requestId untuk mengaitkan data input dengan data output. Anda dapat menggunakan ID permintaan dalam data input untuk mendapatkan hasil inferensi dari antrian output.

Tanyakan Hasil Inferensi Asinkron

Saat menggunakan layanan antrian bersama dengan layanan inferensi, layanan inferensi secara otomatis mengambil data permintaan dari antrian input, melakukan inferensi, lalu menulis hasilnya ke antrian output (antrian sink). Contoh kode berikut memberikan contoh tentang cara menanyakan data dari layanan antrian output menggunakan ID permintaan 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

Keluaran berikut dikembalikan:

> 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}]

Bersihkan data

Jika Anda tidak lagi memerlukan data tertentu dalam antrian Anda, Anda dapat membersihkan data tersebut dengan memanggil operasi API. Anda dapat menghapus satu entri data atau melakukan pemotongan data untuk menghapus beberapa entri data.

Hapus Satu Entri Data

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

Keluaran berikut dikembalikan:

> 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 menanyakan hasil inferensi.

Parameter	Tipe	Deskripsi
_index_	INT	Indeks data yang ingin Anda hapus.

Hapus Beberapa Entri Data

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

Keluaran berikut dikembalikan:

> 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 menanyakan hasil inferensi.

Parameter	Tipe	Deskripsi
_index_	INT	Indeks akhir data yang ingin Anda hapus. Data dengan indeks lebih rendah dari indeks akhir dihapus.
_trunc_	BOOL	Jika Anda ingin menghapus beberapa entri sekaligus, atur parameter ini ke true. Jika tidak, hanya satu entri data yang dihapus.

Berlangganan layanan antrian

Selain penanyaan, Anda dapat berlangganan layanan antrian untuk mendapatkan hasil inferensi asinkron. Layanan antrian menyediakan watch sebagai antarmuka langganan. Klien dapat menggunakan antarmuka watch untuk mendapatkan hasil inferensi. Layanan antrian mengontrol ukuran jendela langganan berdasarkan batas konkurensi atas (worker_threads) dari instance layanan inferensi. Saat data baru ditulis ke antrian, layanan antrian secara otomatis mendorong data ke klien.

Fitur ini diimplementasikan menggunakan QueueClient yang dienkapsulasi dalam SDK berbasis WebSocket. Fitur ini mendorong data melalui koneksi persisten. Dalam contoh berikut, layanan pemrosesan video dan audio digunakan untuk menjelaskan cara menggunakan QueueClient di EAS SDK untuk Python untuk berlangganan data dalam antrian.

Catatan

Layanan inferensi bersifat opsional. Anda dapat menggunakan SDK untuk berlangganan antrian input dari layanan kustom dan menulis data keluaran ke antrian pesan pihak ketiga atau penyimpanan data. Sebagai contoh, Anda dapat mengeluarkan gambar ke Object Storage Service (OSS).

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

Anda dapat menggunakan fungsi put() dari QueueClient untuk mengirim data ke antrian input, dan menggunakan fungsi watch() untuk berlangganan data dari antrian output. Transmisi data dan langganan dapat terjadi di thread yang berbeda. Dalam contoh ini, keduanya diselesaikan dalam thread yang sama dengan menggunakan fungsi put dan watch.

#!/usr/bin/env python
from eas_prediction import QueueClient
# Buat objek antrian input untuk menerima data input.
input_queue = QueueClient('182848887922****.cn-shanghai.pai-eas.aliyuncs.com', 'qservice')
# Untuk membuat pengguna dan grup kustom, tentukan pengguna dengan menggunakan uid dan grup dengan menggunakan 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 hasil pemrosesan di antrian output.
sink_queue = QueueClient('182848887922****.cn-shanghai.pai-eas.aliyuncs.com', 'qservice/sink')
sink_queue.set_token('YmE3NDkyMzdiMzNmMGM3ZmE4ZmNjZDk0M2NiMDA3OTZmNzc1MT****==')
sink_queue.init()

# Dorong 10 entri data ke setiap 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)

# Berlangganan data di antrian output. Ukuran jendela adalah 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 manual setelah setiap permintaan diproses.
    sink_queue.commit(x.index)
    i += 1
    if i == 10:
        break
# Nonaktifkan objek watcher. Setiap klien hanya dapat menggunakan satu objek watcher. Jika Anda tidak menonaktifkan objek watcher, kesalahan akan terjadi saat Anda menjalankan ulang klien.
watcher.close()

Gunakan klien EASCMD untuk mengakses layanan antrian

Klien EASCMD mengenkapsulasi API lengkap layanan antrian. Anda dapat menjalankan subperintah eascmd stream untuk mengelola dan men-debug layanan antrian.

Unduh klien EASCMD

Pastikan bahwa versi EASCMD adalah lebih baru dari 2.6.0. Untuk informasi tentang cara mengunduh, memperbarui, dan mengonfigurasi klien EASCMD, lihat Unduh Klien EASCMD dan Selesaikan Otentikasi Pengguna.

Konfigurasikan EASCMD untuk mengakses layanan antrian

Jalankan perintah eascmd stream config berikut untuk mengonfigurasi akses ke layanan antrian:

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

Setelah menyelesaikan konfigurasi, EASCMD menggunakan default_group sebagai group_id default dan default_user sebagai user_id default. Untuk informasi tentang grup dan pengguna, lihat Langganan dan Pendorongan Layanan Antrian. Anda dapat menggunakan parameter --group dan --user untuk membuat group_id dan user_id kustom. Semua parameter dalam perintah eascmd stream config dapat ditimpa oleh perintah baca dan tulis lainnya.

Tanyakan detail antrian

Jalankan perintah info untuk melihat detail antrian. Contoh kode:

eascmd stream info

Keluaran berikut dikembalikan:

[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 tentang parameter dalam respons, lihat bagian Akses Layanan Antrian dengan Memanggil Operasi API dari topik ini. Anda dapat menggunakan perintah info untuk mendapatkan atribut antrian dan menguji konektivitas ke layanan antrian.

Kirim data ke antrian

Jalankan perintah put untuk mengirim data ke antrian. Contoh kode:

eascmd stream put -d "10s"

Keluaran berikut dikembalikan:

[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 mengirim semua data dalam file ke antrian dengan menggunakan parameter -f. Contoh kode:

eascmd stream put -f test.data

Keluaran berikut dikembalikan:

[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
....

Dalam hal ini, Anda dapat menjalankan perintah info untuk melihat status antrian.

Tanyakan data dalam antrian

Jalankan perintah get untuk menanyakan data dari antrian. Contoh kode:

eascmd stream get -l10 --timeout=3s

Keluaran berikut dikembalikan:

[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
...

Pada entri data pertama yang diterima:

Kolom [0 - 1] menunjukkan bahwa indeks data 0 adalah 1.
Kolom tags[Header:Content-Type=text/plain; charset= ...] menunjukkan bahwa data tersebut mengandung tag. Dalam respons sebelumnya:
- Header menunjukkan header permintaan HTTP saat Anda memasukkan data.
- requestId menunjukkan ID permintaan bawaan yang dibuat secara otomatis.
- ts@source menunjukkan timestamp UNIX saat antrian input menerima permintaan. ts@sink menunjukkan timestamp saat antrian output menerima data.
Kolom terakhir menunjukkan data yang Anda masukkan.

Penting

Jika antrian cocok dengan instance layanan inferensi, data input mungkin dikonsumsi oleh instance setelah data dikirim ke antrian. Dalam hal ini, tambahkan parameter -k ke perintah untuk menanyakan data di antrian output.

Anda juga dapat menggunakan parameter --tags untuk menambahkan kondisi penanyaan. Sebagai contoh, jalankan perintah berikut untuk menanyakan data menggunakan requestId:

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

Keluaran berikut dikembalikan:

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

Hapus data dari antrian

Anda dapat menjalankan perintah delete untuk menghapus satu entri data atau perintah trunc untuk menghapus beberapa entri data. Bagian berikut menyediakan contoh.

Hapus satu entri data:

 eascmd stream delete 3

Setelah entri data dihapus, keluaran berikut dikembalikan:

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

Hapus beberapa entri data:

eascmd stream trunc 4

Setelah entri data dihapus, keluaran berikut dikembalikan:

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

Berlangganan antrian

Jalankan perintah watch untuk berlangganan layanan antrian. Contoh kode:

 eascmd stream watch

Keluaran berikut dikembalikan:

[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]

Masukkan Y untuk melakukan commit dan mendapatkan 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]

Masukkan n untuk menentukan apakah akan 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 tentang commit dan negative commit, lihat bagian "Commit and Negative" dalam topik Langganan dan Pendorongan Layanan Antrian.

Jika Anda menggunakan opsi --auto-commit, data secara otomatis dicommit di server:

 eascmd stream  watch --auto-commit

Keluaran berikut dikembalikan:

[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 yang paling sering digunakan dari eascmd stream. Untuk informasi tentang fungsi ekstensi eascmd stream, jalankan perintah eascmd stream help.