Examples

Messages

You can run the async code by importing AsyncQStash from qstash and awaiting the methods.

Messages are removed from the database shortly after they're delivered, so you will not be able to retrieve a message after. This endpoint is intended to be used for accessing messages that are in the process of being delivered/retried.

Retrieve a message

from qstash import QStashclient = QStash("<QSTASH-TOKEN>")msg = client.message.get("<msg-id>")

Cancel/delete a message

from qstash import QStashclient = QStash("<QSTASH-TOKEN>")client.message.cancel("<msg-id>")

Cancel messages in bulk

Cancel many messages at once or cancel all messages

from qstash import QStashclient = QStash("<QSTASH-TOKEN>")# cancel more than one messageclient.message.cancel_many(["<msg-id-0>", "<msg-id-1>"])# cancel all messagesclient.message.cancel_all()
Loading search…