ກ່ຽວກັບ
Queue Service ສົ່ງຂໍ້ຄວາມຈາກສ່ວນຂອງລະບົບທີ່ສ້າງວຽກໄປຫາ Worker ທີ່ເຮັດວຽກນັ້ນ ຂໍ້ຄວາມທີ່ຖືກຮັບຈະຖືກເຊື່ອງໄວ້ຕາມ Visibility timeout ເມື່ອວຽກສຳເລັດໃຫ້ ack (ລຶບດ້ວຍ receipt) ບໍ່ດັ່ງນັ້ນຂໍ້ຄວາມຈະຖືກສົ່ງອອກອີກຄັ້ງ ຂໍ້ຄວາມຖືກສົ່ງຢ່າງໜ້ອຍໜຶ່ງຄັ້ງ ສະນັ້ນໃຫ້ອອກແບບວຽກໃຫ້ເຮັດຊ້ຳໄດ້ໂດຍບໍ່ເສຍຫາຍ
| ຕັ້ງຄ່າ | ຄ່າເລີ່ມຕົ້ນ | ຊ່ວງທີ່ຕັ້ງໄດ້ |
|---|---|---|
--visibility-timeout | 30 ວິນາທີ | 0 ວິນາທີ – 12 ຊົ່ວໂມງ |
--retention | 4 ມື້ | 1 ນາທີ – 14 ມື້ |
--delay | 0 | 0 – 15 ນາທີ |
--max-receives | 0 (ບໍ່ຈຳກັດ) | 0 – 1,000 ແລ້ວຍ້າຍໄປ Queue --dead-letter |
ຂໍ້ຄວາມໜຶ່ງໃຫຍ່ສຸດ 256 KiB ລວມ body ແລະ attribute ໄລຍະເວລາໃສ່ເປັນ 30s, 5m, 2h, 4d ຫຼື 1d12h ຄຳສັ່ງຂໍ້ຄວາມໃຊ້ Access key ຂອງ Queue Service (Key ຊົ່ວຄາວເມື່ອທ່ານເຂົ້າສູ່ລະບົບ ຫຼື TH_QUEUE_KEY_ID / TH_QUEUE_SECRET) ເບິ່ງເພີ່ມ Queue Service ເຮັດວຽກແນວໃດ
ວິທີເຮັດ
ສ້າງ Queue ພ້ອມ Dead-letter queue
th queue create jobs-dlq
th queue create jobs --visibility-timeout 60s --max-receives 5 --dead-letter jobs-dlqຂໍ້ຄວາມທີ່ຖືກຮັບເກີນ 5 ຄັ້ງໂດຍບໍ່ຖືກ ack ຈະຍ້າຍໄປ jobs-dlq ເຊິ່ງທ່ານເບິ່ງໄດ້ດ້ວຍ th queue peek jobs-dlq
ສົ່ງຂໍ້ຄວາມ
th queue send jobs '{"order": 1042}'
th queue send jobs --file job.json --attr type=invoice
echo "hello" | th queue send jobs -
th queue send jobs '{"order": 1043}' --delay 10sຮັບ ແລະ ack
- ຮັບ:
th queue receive jobs --max 10ແຕ່ລະຂໍ້ຄວາມຖືກພິມພ້ອມ receipt - ເຮັດວຽກ
- ack ແຕ່ລະຂໍ້ຄວາມ:
th queue ack jobs RECEIPT…ຫຼື ໃສ່--ackໃຫ້ receive ເພື່ອ ack ທັນທີຫຼັງພິມ
th queue receive jobs --max 10 --wait 20s
th queue ack jobs <receipt-1> <receipt-2>Tail Queue
th queue tail ລໍຂໍ້ຄວາມ ພິມແຕ່ລະຂໍ້ຄວາມ ແລະ ack ມັນ ຈົນກວ່າທ່ານກົດ Ctrl+C ໃຊ້ --no-ack ເພື່ອເບິ່ງໂດຍບໍ່ກິນຂໍ້ຄວາມ (ຂໍ້ຄວາມຈະກັບມາຫຼັງ Visibility timeout) ແລະ --format json ສຳລັບ JSON object ໜຶ່ງຕໍ່ແຖວ
th queue tail jobs
th queue tail jobs --no-ack --format json | jq .bodyຄຳສັ່ງ
| ຄຳສັ່ງ | ຄຳອະທິບາຍ |
|---|---|
th queue create | ສ້າງ Queue |
th queue list | ສະແດງ Queue ຂອງ Project ພ້ອມຂໍ້ຄວາມທີ່ຄ້າງ |
th queue describe | ສະແດງການຕັ້ງຄ່າ endpoint ແລະ ຂໍ້ຄວາມທີ່ຄ້າງຂອງ Queue |
th queue update | ປ່ຽນການຕັ້ງຄ່າຂອງ Queue ການຕັ້ງຄ່າທີ່ບໍ່ໃສ່ຈະຄົງເດີມ |
th queue send | ສົ່ງຂໍ້ຄວາມໜຶ່ງ |
th queue receive | ຮັບຂໍ້ຄວາມສູງສຸດ --max ຂໍ້ຄວາມ (1-10 ຄ່າເລີ່ມຕົ້ນ 1) ລໍຂໍ້ຄວາມທຳອິດໄດ້ສູງສຸດ --wait (ບໍ່ເກີນ 20s) |
th queue ack | ack (ລຶບ) ຂໍ້ຄວາມທີ່ຮັບແລ້ວດ້ວຍ receipt |
th queue tail | ຮັບຂໍ້ຄວາມເມື່ອມາຮອດ (long polling) ແລະ ພິມອອກ ຂໍ້ຄວາມລະໜຶ່ງບລັອກ (JSON object ໜຶ່ງຕໍ່ແຖວເມື່ອໃຊ້ --format json) |
th queue peek | ສະແດງຂໍ້ຄວາມທີ່ລໍຢູ່ສູງສຸດ 10 ຂໍ້ຄວາມໂດຍບໍ່ຮັບ (ຂໍ້ຄວາມຍັງຢູ່ໃນ Queue ແລະ ຈຳນວນຄັ້ງທີ່ຮັບບໍ່ປ່ຽນ) |
th queue purge | ລຶບທຸກຂໍ້ຄວາມໃນ Queue ໂດຍ Queue ຍັງຢູ່ |
th queue delete | ລຶບ Queue ພ້ອມຂໍ້ຄວາມທັງໝົດ |
th queue create
ສ້າງ Queue
ຮູບແບບຄຳສັ່ງ
th queue create NAME [--region REGION] [--visibility-timeout 30s]
[--retention 4d] [--delay 0s] [--max-receives N --dead-letter QUEUE]ຊື່ມີ 1-80 ຕົວ A-Z, a-z, 0-9, _ ແລະ - ການຕັ້ງຄ່າທີ່ບໍ່ໃສ່ຈະໃຊ້ຄ່າເລີ່ມຕົ້ນຂອງບໍລິການ ໄລຍະເວລາໃສ່ເປັນ 30s, 5m, 2h, 4d ຫຼື 1d12h
ຕົວຢ່າງ
Worker ມີເວລາ 60 ວິນາທີຕໍ່ຂໍ້ຄວາມ
th queue create jobs --visibility-timeout 60sຍ້າຍຂໍ້ຄວາມທີ່ລົ້ມເຫຼວໄປ jobs-dlq
th queue create jobs --max-receives 5 --dead-letter jobs-dlqອາກິວເມັນຕາມຕຳແໜ່ງ
| ຊື່ | ຄຳອະທິບາຍ |
|---|---|
NAMEຕ້ອງໃສ່ | ຊື່ Queue: 1–80 ຕົວ A-Z, a-z, 0-9, _ ແລະ - |
ພາຣາມິເຕີ
| ຊື່ | ປະເພດ | ຄ່າເລີ່ມຕົ້ນ | ຄຳອະທິບາຍ |
|---|---|---|---|
--visibility-timeout | ຂໍ້ຄວາມ | ຂໍ້ຄວາມທີ່ຖືກຮັບຖືກເຊື່ອງໄວ້ດົນເທົ່າໃດ (ເຊັ່ນ 30s, 5m, 12h) | |
--retention | ຂໍ້ຄວາມ | ເກັບຂໍ້ຄວາມໄວ້ດົນເທົ່າໃດ (ເຊັ່ນ 1h, 4d, 14d) | |
--delay | ຂໍ້ຄວາມ | ເວລາລໍກ່ອນຂໍ້ຄວາມໃໝ່ຈະຖືກຮັບໄດ້ (ເຊັ່ນ 0s, 10s, 15m) | |
--max-receives | ຕົວເລກ | ຈຳນວນຄັ້ງທີ່ຮັບກ່ອນຂໍ້ຄວາມຍ້າຍໄປ Dead-letter queue (0 = ບໍ່ຈຳກັດ) | |
--dead-letter | ຂໍ້ຄວາມ | Dead-letter queue ໃນ Project ດຽວກັນ ("" ຫຼື none ເພື່ອລຶບອອກ) |
ພາຣາມິເຕີທົ່ວໄປ
ຄຳສັ່ງນີ້ຮັບ ພາຣາມິເຕີທົ່ວໄປ ໄດ້ນຳ: --project, --region, --endpoint, --format, --quiet
th queue list
ສະແດງ Queue ຂອງ Project ພ້ອມຂໍ້ຄວາມທີ່ຄ້າງ
ຮູບແບບຄຳສັ່ງ
th queue listຕົວຢ່າງ
Queue ແລະ ຂໍ້ຄວາມທີ່ຄ້າງ
th queue listພາຣາມິເຕີທົ່ວໄປ
ຄຳສັ່ງນີ້ຮັບ ພາຣາມິເຕີທົ່ວໄປ ໄດ້ນຳ: --project, --region, --endpoint, --format, --quiet
th queue describe
ສະແດງການຕັ້ງຄ່າ endpoint ແລະ ຂໍ້ຄວາມທີ່ຄ້າງຂອງ Queue
ຮູບແບບຄຳສັ່ງ
th queue describe NAMEຕົວຢ່າງ
ການຕັ້ງຄ່າ endpoint ແລະ ຂໍ້ຄວາມທີ່ຄ້າງ
th queue describe jobsອາກິວເມັນຕາມຕຳແໜ່ງ
| ຊື່ | ຄຳອະທິບາຍ |
|---|---|
NAMEຕ້ອງໃສ່ | ຊື່ Queue: 1–80 ຕົວ A-Z, a-z, 0-9, _ ແລະ - |
ພາຣາມິເຕີທົ່ວໄປ
ຄຳສັ່ງນີ້ຮັບ ພາຣາມິເຕີທົ່ວໄປ ໄດ້ນຳ: --project, --region, --endpoint, --format, --quiet
th queue update
ປ່ຽນການຕັ້ງຄ່າຂອງ Queue ການຕັ້ງຄ່າທີ່ບໍ່ໃສ່ຈະຄົງເດີມ
ຮູບແບບຄຳສັ່ງ
th queue update NAME [--visibility-timeout 30s] [--retention 4d]
[--delay 0s] [--max-receives N] [--dead-letter QUEUE|none]ໄລຍະເວລາໃສ່ເປັນ 30s, 5m, 2h, 4d ຫຼື 1d12h
ຕົວຢ່າງ
ເກັບຂໍ້ຄວາມ 14 ມື້
th queue update jobs --retention 14dເລີກໃຊ້ Dead-letter queue
th queue update jobs --dead-letter noneອາກິວເມັນຕາມຕຳແໜ່ງ
| ຊື່ | ຄຳອະທິບາຍ |
|---|---|
NAMEຕ້ອງໃສ່ | ຊື່ Queue: 1–80 ຕົວ A-Z, a-z, 0-9, _ ແລະ - |
ພາຣາມິເຕີ
| ຊື່ | ປະເພດ | ຄ່າເລີ່ມຕົ້ນ | ຄຳອະທິບາຍ |
|---|---|---|---|
--visibility-timeout | ຂໍ້ຄວາມ | ຂໍ້ຄວາມທີ່ຖືກຮັບຖືກເຊື່ອງໄວ້ດົນເທົ່າໃດ (ເຊັ່ນ 30s, 5m, 12h) | |
--retention | ຂໍ້ຄວາມ | ເກັບຂໍ້ຄວາມໄວ້ດົນເທົ່າໃດ (ເຊັ່ນ 1h, 4d, 14d) | |
--delay | ຂໍ້ຄວາມ | ເວລາລໍກ່ອນຂໍ້ຄວາມໃໝ່ຈະຖືກຮັບໄດ້ (ເຊັ່ນ 0s, 10s, 15m) | |
--max-receives | ຕົວເລກ | ຈຳນວນຄັ້ງທີ່ຮັບກ່ອນຂໍ້ຄວາມຍ້າຍໄປ Dead-letter queue (0 = ບໍ່ຈຳກັດ) | |
--dead-letter | ຂໍ້ຄວາມ | Dead-letter queue ໃນ Project ດຽວກັນ ("" ຫຼື none ເພື່ອລຶບອອກ) |
ພາຣາມິເຕີທົ່ວໄປ
ຄຳສັ່ງນີ້ຮັບ ພາຣາມິເຕີທົ່ວໄປ ໄດ້ນຳ: --project, --region, --endpoint, --format, --quiet
th queue send
ສົ່ງຂໍ້ຄວາມໜຶ່ງ
ຮູບແບບຄຳສັ່ງ
th queue send NAME [MESSAGE | - | --file FILE] [--attr KEY=VALUE ...] [--delay 10s]body ແມ່ນ MESSAGE ເນື້ອໃນຂອງ FILE ຫຼື standard input ເມື່ອ MESSAGE ແມ່ນ - ຂໍ້ຄວາມໜຶ່ງໃຫຍ່ສຸດ 256 KiB (body ແລະ attribute) --delay ເຊື່ອງຂໍ້ຄວາມໄວ້ກ່ອນໄດ້ສູງສຸດ 15m (ຄ່າເລີ່ມຕົ້ນ: ຂອງ Queue)
ຕົວຢ່າງ
ສົ່ງ body ເປັນ JSON
th queue send jobs '{"order": 1042}'body ຈາກໄຟລ໌ ພ້ອມ attribute
th queue send jobs --file job.json --attr type=invoicebody ຈາກ standard input
echo "hello" | th queue send jobs -ອາກິວເມັນຕາມຕຳແໜ່ງ
| ຊື່ | ຄຳອະທິບາຍ |
|---|---|
NAMEຕ້ອງໃສ່ | ຊື່ Queue: 1–80 ຕົວ A-Z, a-z, 0-9, _ ແລະ - |
MESSAGE|-ບໍ່ບັງຄັບ | body ຂອງຂໍ້ຄວາມ ຫຼື - ເພື່ອອ່ານຈາກ standard input ບໍ່ຕ້ອງໃສ່ເມື່ອໃຊ້ --file |
ພາຣາມິເຕີ
| ຊື່ | ປະເພດ | ຄ່າເລີ່ມຕົ້ນ | ຄຳອະທິບາຍ |
|---|---|---|---|
--file | ຂໍ້ຄວາມ | ອ່ານ body ຈາກ FILE | |
--attr | ລາຍການ | Attribute KEY=VALUE (ໃສ່ຊ້ຳໄດ້) | |
--delay | ຂໍ້ຄວາມ | ເວລາລໍກ່ອນຈະຖືກຮັບໄດ້ (ເຊັ່ນ 10s, 5m) |
ພາຣາມິເຕີທົ່ວໄປ
ຄຳສັ່ງນີ້ຮັບ ພາຣາມິເຕີທົ່ວໄປ ໄດ້ນຳ: --project, --region, --endpoint, --format, --quiet
th queue receive
ຮັບຂໍ້ຄວາມສູງສຸດ --max ຂໍ້ຄວາມ (1-10 ຄ່າເລີ່ມຕົ້ນ 1) ລໍຂໍ້ຄວາມທຳອິດໄດ້ສູງສຸດ --wait (ບໍ່ເກີນ 20s)
ຮູບແບບຄຳສັ່ງ
th queue receive NAME [--max 10] [--wait 20s] [--visibility 30s] [--ack]ຂໍ້ຄວາມທີ່ຮັບແລ້ວຖືກເຊື່ອງໄວ້ຕາມ Visibility timeout ໃຫ້ ack ທຸກຂໍ້ຄວາມທີ່ເຮັດແລ້ວ (th queue ack NAME RECEIPT) ບໍ່ດັ່ງນັ້ນຈະຖືກສົ່ງອອກອີກຄັ້ງ --ack ack ທັນທີຫຼັງພິມ
ຕົວຢ່າງ
ຮັບສູງສຸດ 10 ຂໍ້ຄວາມ
th queue receive jobs --max 10ຮັບໜຶ່ງຂໍ້ຄວາມ ແລະ ack ທັນທີ
th queue receive jobs --ackອາກິວເມັນຕາມຕຳແໜ່ງ
| ຊື່ | ຄຳອະທິບາຍ |
|---|---|
NAMEຕ້ອງໃສ່ | ຊື່ Queue: 1–80 ຕົວ A-Z, a-z, 0-9, _ ແລະ - |
ພາຣາມິເຕີ
| ຊື່ | ປະເພດ | ຄ່າເລີ່ມຕົ້ນ | ຄຳອະທິບາຍ |
|---|---|---|---|
--max | ຕົວເລກ | 1 | ຈຳນວນຂໍ້ຄວາມທີ່ຈະຮັບ 1-10 |
--wait | ຂໍ້ຄວາມ | Long-poll ລໍຂໍ້ຄວາມທຳອິດໄດ້ດົນເທົ່ານີ້ (ບໍ່ເກີນ 20s) | |
--visibility | ຂໍ້ຄວາມ | ເຊື່ອງຂໍ້ຄວາມທີ່ຮັບໄວ້ດົນເທົ່ານີ້ ແທນ timeout ຂອງ Queue | |
--ack | ແຟລັກ | ack (ລຶບ) ຂໍ້ຄວາມຫຼັງພິມ |
ພາຣາມິເຕີທົ່ວໄປ
ຄຳສັ່ງນີ້ຮັບ ພາຣາມິເຕີທົ່ວໄປ ໄດ້ນຳ: --project, --region, --endpoint, --format, --quiet
th queue ack
ack (ລຶບ) ຂໍ້ຄວາມທີ່ຮັບແລ້ວດ້ວຍ receipt
ຮູບແບບຄຳສັ່ງ
th queue ack NAME RECEIPT...ການ ack ຂໍ້ຄວາມຊ້ຳບໍ່ຖືວ່າເປັນ error
ຕົວຢ່າງ
ack ຂໍ້ຄວາມທີ່ເຮັດແລ້ວ
th queue ack jobs <receipt>ອາກິວເມັນຕາມຕຳແໜ່ງ
| ຊື່ | ຄຳອະທິບາຍ |
|---|---|
NAMEຕ້ອງໃສ່ | ຊື່ Queue: 1–80 ຕົວ A-Z, a-z, 0-9, _ ແລະ - |
RECEIPT…ຕ້ອງໃສ່ | receipt ທີ່ພິມມາກັບແຕ່ລະຂໍ້ຄວາມທີ່ຮັບ ໃສ່ຫຼາຍອັນເພື່ອ ack ພ້ອມກັນ |
ພາຣາມິເຕີທົ່ວໄປ
ຄຳສັ່ງນີ້ຮັບ ພາຣາມິເຕີທົ່ວໄປ ໄດ້ນຳ: --project, --region, --endpoint, --format, --quiet
th queue tail
ຮັບຂໍ້ຄວາມເມື່ອມາຮອດ (long polling) ແລະ ພິມອອກ ຂໍ້ຄວາມລະໜຶ່ງບລັອກ (JSON object ໜຶ່ງຕໍ່ແຖວເມື່ອໃຊ້ --format json)
ຮູບແບບຄຳສັ່ງ
th queue tail NAME [--no-ack] [--max 10] [--visibility 30s]ທຸກຂໍ້ຄວາມທີ່ພິມຖືກ ack ເວັ້ນແຕ່ໃສ່ --no-ack ສະນັ້ນ tail ເຮັດວຽກເປັນ consumer ດ້ວຍ --no-ack ຂໍ້ຄວາມຈະຖືກສົ່ງອອກອີກຄັ້ງຫຼັງ Visibility timeout ກົດ Ctrl+C ເພື່ອຢຸດ
ຕົວຢ່າງ
ກິນຂໍ້ຄວາມຈົນກວ່າກົດ Ctrl+C
th queue tail jobsເບິ່ງໂດຍບໍ່ກິນ JSON object ໜຶ່ງຕໍ່ແຖວ
th queue tail jobs --no-ack --format jsonອາກິວເມັນຕາມຕຳແໜ່ງ
| ຊື່ | ຄຳອະທິບາຍ |
|---|---|
NAMEຕ້ອງໃສ່ | ຊື່ Queue: 1–80 ຕົວ A-Z, a-z, 0-9, _ ແລະ - |
ພາຣາມິເຕີ
| ຊື່ | ປະເພດ | ຄ່າເລີ່ມຕົ້ນ | ຄຳອະທິບາຍ |
|---|---|---|---|
--max | ຕົວເລກ | 10 | ຈຳນວນຂໍ້ຄວາມຕໍ່ການຮັບ 1-10 |
--visibility | ຂໍ້ຄວາມ | ເຊື່ອງຂໍ້ຄວາມທີ່ຮັບໄວ້ດົນເທົ່ານີ້ ແທນ timeout ຂອງ Queue | |
--ack | ແຟລັກ | true | ack ທຸກຂໍ້ຄວາມທີ່ພິມ (ຄ່າເລີ່ມຕົ້ນ true; --no-ack ປະຂໍ້ຄວາມໄວ້) --no-ack ປິດຄ່ານີ້ |
ພາຣາມິເຕີທົ່ວໄປ
ຄຳສັ່ງນີ້ຮັບ ພາຣາມິເຕີທົ່ວໄປ ໄດ້ນຳ: --project, --region, --endpoint, --format, --quiet
th queue peek
ສະແດງຂໍ້ຄວາມທີ່ລໍຢູ່ສູງສຸດ 10 ຂໍ້ຄວາມໂດຍບໍ່ຮັບ (ຂໍ້ຄວາມຍັງຢູ່ໃນ Queue ແລະ ຈຳນວນຄັ້ງທີ່ຮັບບໍ່ປ່ຽນ)
ຮູບແບບຄຳສັ່ງ
th queue peek NAMEຕົວຢ່າງ
ເບິ່ງຂໍ້ຄວາມທີ່ລໍຢູ່ໂດຍບໍ່ຮັບ
th queue peek jobs-dlqອາກິວເມັນຕາມຕຳແໜ່ງ
| ຊື່ | ຄຳອະທິບາຍ |
|---|---|
NAMEຕ້ອງໃສ່ | ຊື່ Queue: 1–80 ຕົວ A-Z, a-z, 0-9, _ ແລະ - |
ພາຣາມິເຕີທົ່ວໄປ
ຄຳສັ່ງນີ້ຮັບ ພາຣາມິເຕີທົ່ວໄປ ໄດ້ນຳ: --project, --region, --endpoint, --format, --quiet
th queue purge
ລຶບທຸກຂໍ້ຄວາມໃນ Queue ໂດຍ Queue ຍັງຢູ່
ຮູບແບບຄຳສັ່ງ
th queue purge NAME [--quiet]--quiet ຂ້າມການຖາມຢືນຢັນ
ຕົວຢ່າງ
ລຶບທຸກຂໍ້ຄວາມ ບໍ່ຖາມ
th queue purge jobs --quietອາກິວເມັນຕາມຕຳແໜ່ງ
| ຊື່ | ຄຳອະທິບາຍ |
|---|---|
NAMEຕ້ອງໃສ່ | ຊື່ Queue: 1–80 ຕົວ A-Z, a-z, 0-9, _ ແລະ - |
ພາຣາມິເຕີທົ່ວໄປ
ຄຳສັ່ງນີ້ຮັບ ພາຣາມິເຕີທົ່ວໄປ ໄດ້ນຳ: --project, --region, --endpoint, --format, --quiet
th queue delete
ລຶບ Queue ພ້ອມຂໍ້ຄວາມທັງໝົດ
ຮູບແບບຄຳສັ່ງ
th queue delete NAME [--quiet]--quiet ຂ້າມການຖາມຢືນຢັນ
ຕົວຢ່າງ
ລຶບ Queue ແລະ ຂໍ້ຄວາມຂອງມັນ
th queue delete jobsອາກິວເມັນຕາມຕຳແໜ່ງ
| ຊື່ | ຄຳອະທິບາຍ |
|---|---|
NAMEຕ້ອງໃສ່ | ຊື່ Queue: 1–80 ຕົວ A-Z, a-z, 0-9, _ ແລະ - |
ພາຣາມິເຕີທົ່ວໄປ
ຄຳສັ່ງນີ້ຮັບ ພາຣາມິເຕີທົ່ວໄປ ໄດ້ນຳ: --project, --region, --endpoint, --format, --quiet