B
B
B
M
H
D
KK
AAA
3
D
PAAA
AAP
R
leading option for it.
MRRR
caches.default but the requests seemd to hit before the cache write and subsequent read had updatedRR
A await env.QUEUE.send(message)
AR
cloudflare:test module.
SA
A
D
ctx.waitUntil(promisse) followed by a msg.ack{} it does not receive other batches until all messages on this batch finishes processing.A
ctx.waitUntil
C
promise.allSettled, egDCDC
nah makes plenty of sense im wrestling with the same thing nowDCD
J
I've got some messages that are missing
leadingcaches.default await env.QUEUE.send(message)
cloudflare:testctx.waitUntil(promisse)msg.ack{}promise.allSettledasync queue(batch, env, ctx) {
for (const message of batch.messages) {
try {
ctx.waitUntil(processBody(message.body))
message.ack()
} catch (e) {
message.retry()
}
}
}async queue(batch, env, ctx) {
for (const message of batch.messages) {
try {
//Lots of seconds because call AI APIs and other stuff
await processBody(message.body)
message.ack()
} catch (e) {
message.retry()
}
}
}async queue(batch, env, ctx) {
await Promise.allSettled(
batch.messages.map((message) => processBody(message.body)
.then(() => {
// maybe `res?.ok` if its a fetch or something
message.ack()
})
.catch(() => {
message.retry()
})
)).finally(() => {
console.log('batch completed')
})
}[[queues.consumers]]
queue = "my-webhook"
max_batch_size = 100
max_batch_timeout = 3 #seconds
max_retries = 3
retry_delay = 30 #seconds
dead_letter_queue = "my-webhook-dlq"
max_concurrency = 20