Welcome to the official Cloudflare Developers server. Here you can ask for help and stay updated with the latest news
83,498Members
View on DiscordResources
Similar Threads
Was this page helpful?
query {
viewer {
accounts(filter: { accountTag: $accountId }) {
queueMessageOperationsAdaptiveGroups(
limit: 10000
filter: { date_geq: $startDate, date_leq: $endDate }
orderBy: [date_DESC]
) {
count
sum {
bytes
}
dimensions {
queueId
date
}
}
}
}
}
MMM
A
A
AA
)
A
Well, in this case it meant I exceeded browser rendering limits 
But it's a beta so no sweat, thanks for looking into it!AM
accountTag as defined there.Mwrangler queues list today (we need to add it to the dash)AstartDate?A 
M
AAAAAA
Anodejs_compat.
KKA 
HHA
HHAHA
makes sense
A
env.QUEUE.send(...) is called but the consumer never receives the message. No errors. If there isn't a known limit then I'll pair my case down to the most minimal case, but wanted to check here first.MA
AMA
MAAAA
YHY
await kv_storage.put(id, JSON.stringify(data)) and I want it to go to a queue instead, how would I write that?Kawait env.QUEUE.send(data);KYexport interface Env {
<MY_QUEUE>: Queue<any>;
}K{
"data": {
"viewer": {
"accounts": [
{
"queueMessageOperationsAdaptiveGroups": [
{
"count": 2446,
"dimensions": {
"date": "2024-01-24",
"queueId": "e4d7d7e594bd48bbbe49703f72e9c92a"
},
"sum": {
"bytes": 264168
}
}
]
}
]
}
},
"errors": null
}accountTagwrangler queues liststartDatenodejs_compatenv.QUEUE.send(...)await kv_storage.put(id, JSON.stringify(data))await env.QUEUE.send(data);export interface Env {
<MY_QUEUE>: Queue<any>;
}const v8 = require('v8');
// Serialize an object into a buffer using v8
function serializeWithV8(obj) {
return v8.serialize(obj);
}
// Convert the Buffer to a byte array (Uint8Array)
const byteArray = new Uint8Array(buffer.buffer, buffer.byteOffset, buffer.byteLength);
// Now you can send the byteArray over the network