For some reason, the Cloudflare Dashboard, shows that the queue has no producer worker linked 🤷‍♂️

Nnuno For some reason, the Cloudflare Dashboard, shows that the queue has no producer ...

O

Hey thanks for that clarification. I created two for deployment because I couldn't get local to work (which that now explains it) - PITA to have to then break up for deployment.

OOld Man Maker Hey thanks for that clarification. I created two for deployment because I couldn...

N

nunoOP•9/22/23, 3:33 PM

Still dont know how to link the producer to the queue

O

Old Man Maker•9/22/23, 3:35 PM

I'm not sure if that is because you've got them in the same file? You can try and creaet another Worker and add the producer into that one to see if it links in the dashboard. I can confirm that mine is showing correectly.

OOld Man Maker I'm not sure if that is because you've got them in the same file? You can try an...

N

nunoOP•9/22/23, 3:45 PM

Well, I got it to work. It was the beter-sqlite package facePalm

Nnuno Well, I got it to work. It was the beter-sqlite package <:facePalm:7403809801158...

O

Old Man Maker•9/22/23, 3:46 PM

Nice

OOld Man Maker Nice

N

nunoOP•9/22/23, 3:46 PM

Thanks for your help sir

O

Old Man Maker•9/22/23, 3:47 PM

I was exactly no-help at all

Thanks for sharing what you learnt. That's about the only way to figure some of this out I think

A

Adi//•9/24/23, 5:24 AM

Hi folks is queues beta free to use?

A

Adi//•9/24/23, 5:24 AM

Or I need to be on the workers paid plan for 5$ first?

A

Adi//•9/24/23, 5:25 AM

trying to understand what this means

Screenshot_2023-09-24_at_10.55.26_AM.png

Screenshot_2023-09-24_at_10.55.36_AM.png

AAdi//Or I need to be on the workers paid plan for 5$ first?

K

kian•9/24/23, 5:39 AM

Yep

Kkian Yep

A

Adi//•9/24/23, 6:15 AM

ok thanks!

N

nunoOP•9/26/23, 9:06 AM

Hey guys! I'm using the queue to handle Stripe Events (Webhooks), and I want to make a fetch to another API, but the instant the code reaches the

fetch

fetch

, it just skip / stops running. Yesterday I assumed that the

fetches

fetches

were disabled on the queue, but minutes ago I saw an example on the CF Docs where a

fetch

fetch

is made inside a queue.

https://developers.cloudflare.com/queues/examples/web-crawler-with-browser-rendering/#6-crawl-with-puppeteer

Can someone help me understand what could be the problem?
Thanks in advance.

Nnuno Hey guys! I'm using the queue to handle Stripe Events (Webhooks), and I want to ...

M

Matt Silverlock•9/26/23, 10:47 AM

Can you share your code? Are you correctly

await

await

ing the fetch? Do you have a

try-catch

try-catch

handler and are you seeing any errors logged?

MMatt Silverlock Can you share your code? Are you correctly `await` ing the fetch? Do you have a ...

N

nunoOP•9/26/23, 10:55 AM

Yes, I'm

await

await

ing the

fetch

fetch

and I also put inside a

try/catch

try/catch

, but no error is logged.
The last log I see is the

API URL

API URL

log, and then the code skips everything below the log

try {
    console.log('API URL :', `${env.STRAPI_API_URL}/c-orders`);
    const connection = await fetch(`${env.STRAPI_API_URL}/c-orders`, {
      headers: {
        Authorization: `Bearer ${env.STRAPI_API_KEY}`,
        'Content-Type': 'application/json',
      },
      method: 'POST',
      body: JSON.stringify({
        data: {
          planId,
          date: new Date(),
          deliveryDate: new Date(deliveryDate * 1000),
          status: 1,
          details,
          grossPrice: totalPrice,
          finalPrice: totalPrice,
          subscriptionId: subscription ? strapiSubscriptionId : null,
          userId,
          paymentId: paymentIntent,
          paymentStatus: subscription ? 'processing' : 'success',
          orderInfo: [],
          stripeInvoiceId: invoice,
        },
      }),
    });

    console.log('connection :', connection);
    const data = await connection.json();
    console.log('data :', JSON.stringify(data, null, 2));

    if (connection.status !== 200) wasOrderCreated = false;

    wasOrderCreated = true;
  } catch (err) {
    console.log('err :', err);
    return false;
  }

try {
    console.log('API URL :', `${env.STRAPI_API_URL}/c-orders`);
    const connection = await fetch(`${env.STRAPI_API_URL}/c-orders`, {
      headers: {
        Authorization: `Bearer ${env.STRAPI_API_KEY}`,
        'Content-Type': 'application/json',
      },
      method: 'POST',
      body: JSON.stringify({
        data: {
          planId,
          date: new Date(),
          deliveryDate: new Date(deliveryDate * 1000),
          status: 1,
          details,
          grossPrice: totalPrice,
          finalPrice: totalPrice,
          subscriptionId: subscription ? strapiSubscriptionId : null,
          userId,
          paymentId: paymentIntent,
          paymentStatus: subscription ? 'processing' : 'success',
          orderInfo: [],
          stripeInvoiceId: invoice,
        },
      }),
    });

    console.log('connection :', connection);
    const data = await connection.json();
    console.log('data :', JSON.stringify(data, null, 2));

    if (connection.status !== 200) wasOrderCreated = false;

    wasOrderCreated = true;
  } catch (err) {
    console.log('err :', err);
    return false;
  }

try {
    console.log('API URL :', `${env.STRAPI_API_URL}/c-orders`);
    const connection = await fetch(`${env.STRAPI_API_URL}/c-orders`, {
      headers: {
        Authorization: `Bearer ${env.STRAPI_API_KEY}`,
        'Content-Type': 'application/json',
      },
      method: 'POST',
      body: JSON.stringify({
        data: {
          planId,
          date: new Date(),
          deliveryDate: new Date(deliveryDate * 1000),
          status: 1,
          details,
          grossPrice: totalPrice,
          finalPrice: totalPrice,
          subscriptionId: subscription ? strapiSubscriptionId : null,
          userId,
          paymentId: paymentIntent,
          paymentStatus: subscription ? 'processing' : 'success',
          orderInfo: [],
          stripeInvoiceId: invoice,
        },
      }),
    });

    console.log('connection :', connection);
    const data = await connection.json();
    console.log('data :', JSON.stringify(data, null, 2));

    if (connection.status !== 200) wasOrderCreated = false;

    wasOrderCreated = true;
  } catch (err) {
    console.log('err :', err);
    return false;
  }

try {
    console.log('API URL :', `${env.STRAPI_API_URL}/c-orders`);
    const connection = await fetch(`${env.STRAPI_API_URL}/c-orders`, {
      headers: {
        Authorization: `Bearer ${env.STRAPI_API_KEY}`,
        'Content-Type': 'application/json',
      },
      method: 'POST',
      body: JSON.stringify({
        data: {
          planId,
          date: new Date(),
          deliveryDate: new Date(deliveryDate * 1000),
          status: 1,
          details,
          grossPrice: totalPrice,
          finalPrice: totalPrice,
          subscriptionId: subscription ? strapiSubscriptionId : null,
          userId,
          paymentId: paymentIntent,
          paymentStatus: subscription ? 'processing' : 'success',
          orderInfo: [],
          stripeInvoiceId: invoice,
        },
      }),
    });

    console.log('connection :', connection);
    const data = await connection.json();
    console.log('data :', JSON.stringify(data, null, 2));

    if (connection.status !== 200) wasOrderCreated = false;

    wasOrderCreated = true;
  } catch (err) {
    console.log('err :', err);
    return false;
  }

A

Altrius•9/26/23, 9:04 PM

ok, so I started using Queues yesterday, and whilst the workers SDK is great, the one thing which would be a perfect addition for me would be the

send

send

and

sendBatch

sendBatch

methods returning a single (or array of for batch) string(s) representing each message sent to the queue

those IDs do exist, because they get given to the handler to ack, but theyre not available to the sending worker, it just returns a

Promise<void>

Promise<void>

, is there any chance that this might come along, or even be an option to enable it in the command itself (eg

MY_QUEUE.send('my payload', {resolveId: true})

MY_QUEUE.send('my payload', {resolveId: true})

Im only even mentioning it because I am using Queues alongside an external RabbitMQ server, where I acknowledge a queue job is completed back to my own local server for the next set of tasks to be triggered

A

Adi//•9/27/23, 12:47 PM

In case of workers the workers die when the client disconnects,
What is the case with queues?
Do queue workers have any "wall time or limit" (assuming the other limits like cpu time etc are not exceeded)

CCharlie In what situation are you imaging a queue consumer worker getting disconnected f...

A

Adi//•9/27/23, 8:53 PM

Nothing really, my worker will connect with another api and operate over streamed responses (SSE events) just curious if i still need to worry about Anything

U

Unsmart•9/27/23, 9:48 PM

If the worker errors it wont delete the messages from the queue so they would get retried eventually

UUnsmart If the worker errors it wont delete the messages from the queue so they would ge...

A

Adi//•9/28/23, 5:41 AM

oh this is super cool then imo, trying to understand how this works,

are messages deleted only after a task is completed? or thats upto me

A

Adi//•9/28/23, 5:41 AM

Also I assume duplicacy is handled directly by cloudflare (one message = one worker instance?)

A

Adi//•9/28/23, 5:43 AM

can someone help me understand these 2?

Screenshot_2023-09-28_at_11.13.36_AM.png

Screenshot_2023-09-28_at_11.13.47_AM.png

CCharlie @Adi// messages are deleted in 3 different circumstances - When the message is e...

A

Adi//•9/28/23, 6:45 PM

Got it understood, this helps

A

Adi//•9/28/23, 6:46 PM

Also I assume that means workers have no runtime limits (wall time) until I am well under cpu limits?

G

gideonred•9/29/23, 2:48 PM

Hello, ex-Cloudflarian here

. Two questions:

Is there a timeline for Queues to be supported in Wrangler dev preview mode?
We currently have Queues enabled for our CF prod account, but not non-prod. Our infrastructure team has reached out, but I haven't heard back from my internal team. Any chance someone here is motived to help me get it enabled?

G

gideonred•9/29/23, 2:58 PM

Also, is there a direct HTTP POST I can do to a queue for testing purposes?

M

Matt Silverlock•9/29/23, 5:46 PM

Gideon!

See this note: https://developers.cloudflare.com/queues/learning/local-development/#known-issues
- we’re working on a fix for this but won’t be this month.
Email me your account ID. Queues requires a paid Workers plan - that’s it. What are you seeing that isn’t working if that is the case?
HTTP POST - there is a dash debugging UI for testing. Not yet a REST API you can use.

Local Development · Cloudflare Queues

Queues support local development workflows using Wrangler, the command-line interface for Workers. Wrangler runs the same version of Queues as …

G

gideonred•9/29/23, 8:19 PM

@Matt !

Thanks for 1 and 3.

For 2: we finally got a reply from our Cloudflare TAM and yes, they stated we need to add a payment method on our non-prod account. I'm working on us setting that up.

M

MetalGear•10/2/23, 3:42 PM

Hey guys,

really loving my solution using only cloudflare services for my backend api but im currently suffering from one problem I am hoping someone can guide me. I am using cloudflare queues to manage events that need to be processed say sending a command to a iot device. That iot device 3rd party api has been giving me issues sometimes where its unnavailable for 3 hours due to maintnanace on their end. So when my worker consumes that queue I need a way to keep retrying all the queue items every hour. until they succeed and then I can mark them as consumed.

M

MetalGear•10/2/23, 4:04 PM

Do you guys think i should just use upstash for now if I need those features?

S

switz•10/3/23, 8:07 PM

whats the best way to retry a message in the queue but on a delay?

S

switz•10/3/23, 8:08 PM

will retries happen immediately?

Sswitz whats the best way to retry a message in the queue but on a delay?

M

MetalGear•10/3/23, 10:22 PM

No good way to do that right now unfortunetely based on my limited experience. I needed a solution fast so i just temporarily moved to qstash from upstash

S

switz•10/3/23, 10:46 PM

alternatively, would be nice to consume a queue from an external application. that would solve the problem for me

S

switz•10/3/23, 10:46 PM

so I only consume items when my server is up and running

S

switz•10/3/23, 10:47 PM

maybe this: https://idearium.github.io/idearium-lib/docs/cloudflare-queues

@idearium/cloudflare-queues | Idearium Lib

Safely process Cloudflare Queues batches and messages.

Sswitz so I only consume items when my server is up and running

M

Matt Silverlock•10/4/23, 12:39 AM

This is coming (HTTP Pull) in the future.

S

switz•10/4/23, 12:40 AM

Sweet, I’d really love that.

S

Sameer Ali•10/4/23, 12:41 AM

I am looking at queue api docs, there is no way to send something to queue outside of the worker. Am i missing anything?

SSameer Ali I am looking at queue api docs, there is no way to send something to queue outsi...

M

Matt Silverlock•10/4/23, 12:46 AM

You would need to write a Worker: https://developers.cloudflare.com/queues/get-started/#write-your-producer-worker

Get started · Cloudflare Queues

Cloudflare Queues is a flexible messaging queue that allows you to queue messages for asynchronous processing. By following this guide, you will …

S

Sameer Ali•10/4/23, 12:47 AM

Thanks

�

😈 Donkey 💫•10/4/23, 5:09 AM

my producer is simple:

export interface Env {
    MY_QUEUE: Queue;
}

export default {
    async fetch(req: Request, env: Env, ctx: ExecutionContext): Promise<Response> {

        // if req.method is not POST , reject
        if (req.method !== 'POST') {
            return new Response('Sorry', { status: 405 });
        }
        const body = await req.json();
        console.log(`got body: ${JSON.stringify(body)}`)
        const result = await env.MY_QUEUE.send({
            body: body,
            contentType: "json",
        });
        console.log(`sent message to queue: ${JSON.stringify(result)}`);
        return new Response(JSON.stringify({
            return_code: "1",
            return_message: "ok"
        }), {
            headers: { 'Content-Type': 'application/json' },
        });
    },
};

export interface Env {
    MY_QUEUE: Queue;
}

export default {
    async fetch(req: Request, env: Env, ctx: ExecutionContext): Promise<Response> {

        // if req.method is not POST , reject
        if (req.method !== 'POST') {
            return new Response('Sorry', { status: 405 });
        }
        const body = await req.json();
        console.log(`got body: ${JSON.stringify(body)}`)
        const result = await env.MY_QUEUE.send({
            body: body,
            contentType: "json",
        });
        console.log(`sent message to queue: ${JSON.stringify(result)}`);
        return new Response(JSON.stringify({
            return_code: "1",
            return_message: "ok"
        }), {
            headers: { 'Content-Type': 'application/json' },
        });
    },
};

export interface Env {
    MY_QUEUE: Queue;
}

export default {
    async fetch(req: Request, env: Env, ctx: ExecutionContext): Promise<Response> {

        // if req.method is not POST , reject
        if (req.method !== 'POST') {
            return new Response('Sorry', { status: 405 });
        }
        const body = await req.json();
        console.log(`got body: ${JSON.stringify(body)}`)
        const result = await env.MY_QUEUE.send({
            body: body,
            contentType: "json",
        });
        console.log(`sent message to queue: ${JSON.stringify(result)}`);
        return new Response(JSON.stringify({
            return_code: "1",
            return_message: "ok"
        }), {
            headers: { 'Content-Type': 'application/json' },
        });
    },
};

export interface Env {
    MY_QUEUE: Queue;
}

export default {
    async fetch(req: Request, env: Env, ctx: ExecutionContext): Promise<Response> {

        // if req.method is not POST , reject
        if (req.method !== 'POST') {
            return new Response('Sorry', { status: 405 });
        }
        const body = await req.json();
        console.log(`got body: ${JSON.stringify(body)}`)
        const result = await env.MY_QUEUE.send({
            body: body,
            contentType: "json",
        });
        console.log(`sent message to queue: ${JSON.stringify(result)}`);
        return new Response(JSON.stringify({
            return_code: "1",
            return_message: "ok"
        }), {
            headers: { 'Content-Type': 'application/json' },
        });
    },
};

after make 1 request via PostMan

there's a lots triggering this function, make massive queues produced to the Queue

any of them, has same logs like below:

"logs": [
    {
      "message": [
        "got body: {\"data\":\"dat hart fd3 3\"}"
      ],
      "level": "log",
      "timestamp": 1696396087813
    },
    {
      "message": [
        "sent message to queue: undefined"
      ],
      "level": "log",
      "timestamp": 1696396087867
    }
  ]

"logs": [
    {
      "message": [
        "got body: {\"data\":\"dat hart fd3 3\"}"
      ],
      "level": "log",
      "timestamp": 1696396087813
    },
    {
      "message": [
        "sent message to queue: undefined"
      ],
      "level": "log",
      "timestamp": 1696396087867
    }
  ]

"logs": [
    {
      "message": [
        "got body: {\"data\":\"dat hart fd3 3\"}"
      ],
      "level": "log",
      "timestamp": 1696396087813
    },
    {
      "message": [
        "sent message to queue: undefined"
      ],
      "level": "log",
      "timestamp": 1696396087867
    }
  ]

"logs": [
    {
      "message": [
        "got body: {\"data\":\"dat hart fd3 3\"}"
      ],
      "level": "log",
      "timestamp": 1696396087813
    },
    {
      "message": [
        "sent message to queue: undefined"
      ],
      "level": "log",
      "timestamp": 1696396087867
    }
  ]

what's wrong with my code? or is this a bug? any helps?

�

😈 Donkey 💫•10/4/23, 6:07 AM

found out
it's because the routes endwith wildcard (star), without slashes rightbefore

( domain.com/a* => bug massive trigger)
( domain.com/a/* => works now)

M

marina.lipeck•10/4/23, 10:22 AM

hey guys! is there a way to increase the limit of queues? We used the request form (https://docs.google.com/forms/d/e/1FAIpQLSd_fwAVOboH9SlutMonzbhCxuuuOmiU1L_I5O2CFbXf_XXMRg/viewform) from the docs a couple of weeks ago, but never got any answer

Google Docs

Cloudflare Developer Platform: Limit Increase Request Form

Want to increase the limits of your current plan? Let us know what your requirements are here.

For some reason, the Cloudflare Dashboard, shows that the queue has no producer worker linked 🤷‍♂️

Similar Threads

Similar Threads

Similar Threads