Topics

You can run the async code by importing Client from upstash_qstash.asyncio and awaiting the methods.

Create a topic and add 2 endpoints

from upstash_qstash import Client

client = Client("<QSTASH_TOKEN>")
topics = client.topics()
topics.upsert_or_add_endpoints(
  {
    "name": "topic_name",
    "endpoints": [
      {"url": "https://my-endpoint-1"},
      {"url": "https://my-endpoint-2"}
    ],
  }
)

Get topic by name

from upstash_qstash import Client

client = Client("<QSTASH_TOKEN>")
topics = client.topics()
topic = topics.get("topic_name")
print(topic["name"], topic["endpoints"])

List topics

from upstash_qstash import Client

client = Client("<QSTASH_TOKEN>")
topics = client.topics()
all_topics = topics.list()
for topic in all_topics:
  print(topic["name"], topic["endpoints"])

Remove an endpoint from a topic

from upstash_qstash import Client

client = Client("<QSTASH_TOKEN>")
topics = client.topics()
topics.remove_endpoints(
  {
    "name": "topic_name",
    "endpoints": [
      {"url": "https://my-endpoint-1"},
    ],
  }
)

Delete a topic

from upstash_qstash import Client

client = Client("<QSTASH_TOKEN>")
topics = client.topics()
topics.delete("topic_name")