ServerlessData Platform

import { Redis } from '@upstash/redis'

const redis = new Redis({
  url: 'https://obi-wan-kenobi-31346.upstash.io',
  token: 'TOKEN',
})
   
const data = await redis.set('foo', 'bar');

// Producer
import { Kafka } from "@upstash/kafka"

const kafka = new Kafka({
  url: "https://dart-vader-9500-eu1-rest-kafka.upstash.io",
  username: "USERNAME",
  password: "PASSWORD",
})

const p = kafka.producer()
const res = await p.produce("<my.topic>", { hello: "world" } )

// Consumer
import { Kafka } from "@upstash/kafka"

const kafka = new Kafka({
  url: "https://dart-vader-9500-eu1-rest-kafka.upstash.io",
  username: "USERNAME",
  password: "PASSWORD",
})

const c = kafka.consumer()

const messages = await c.consume({
  consumerGroupId: "group_1",
  instanceId: "instance_1",
  topics: ["test.topic"],
  autoOffsetReset: "earliest",
})

fetch("https://qstash.upstash.io/v2/publish/https://example.com", {
  body: "{ 'hello': 'world' }",
  headers: {
    Authorization: "Bearer XXX",
    "Content-Type": "application/json",
    "Upstash-Forward-My-Header": "my-value"
  },
  method: "POST"
})

from upstash_vector import Index

index = Index(url="https://master-yoda-eu1-vector.upstash.io/query", token="XXX")

index.upsert(
  vectors=[("id-1", [0.72, 0.7], {"meta_key": "meta_value"})]
)

index.query(
  vector=[0.72, 0.7], top_k=1, include_vectors=True, include_metadata=True
)