Appearance
Upstash
Manage serverless Redis and Kafka databases with the Upstash management API.
| Detail | Value |
|---|---|
| Category | Database |
| Base URL | https://api.upstash.com/v2 |
| Authentication | API Key |
| Endpoints | 8 |
| Connector key | upstash |
Using Upstash in a workflow
- Go to Connections and click New Connection.
- Pick Upstash from the marketplace.
- Enter your credentials (see Authentication above for what's expected).
- In a workflow, drop an API Call node and select this connection.
- Pick the operation you need from the Operation dropdown — the full list is below.
Available endpoints
| Endpoint | Summary |
|---|---|
GET /redis/databases | List Redis databases |
POST /redis/databases | Create a Redis database |
GET /redis/database/{id} | Get Redis database details |
DELETE /redis/database/{id} | Delete a Redis database |
GET /redis/database/{id}/stats | Get database statistics |
GET /kafka/clusters | List Kafka clusters |
POST /kafka/clusters | Create a Kafka cluster |
POST /kafka/topic | Create a Kafka topic |
Each endpoint is documented in full below. Use the outline on the right to jump to one.
GET /redis/databases
List Redis databases
| Detail | Value |
|---|---|
| Operation ID | database.listRedisDatabases |
| Method | GET |
| Path | /redis/databases |
Parameters
No parameters.
Using this endpoint in a workflow
- Add an API Call node to your workflow.
- Pick your Upstash connection from the Connection dropdown.
- In the Operation dropdown, select
database.listRedisDatabases. - Fill in the parameter fields that appear. Use
{{...}}to reference upstream values.
What it returns
The API Call node writes the response to the workflow context:
{
status: 200,
success: true,
data: { ...response body from the API... },
latencyMs: 142
}Reference response fields downstream as {{nodeId.data.path}}. The exact response shape is documented on the upstream Upstash API reference.
POST /redis/databases
Create a Redis database
| Detail | Value |
|---|---|
| Operation ID | database.createRedisDatabase |
| Method | POST |
| Path | /redis/databases |
Parameters
No parameters.
Using this endpoint in a workflow
- Add an API Call node to your workflow.
- Pick your Upstash connection from the Connection dropdown.
- In the Operation dropdown, select
database.createRedisDatabase. - Fill in the parameter fields that appear. Use
{{...}}to reference upstream values.
What it returns
The API Call node writes the response to the workflow context:
{
status: 200,
success: true,
data: { ...response body from the API... },
latencyMs: 142
}Reference response fields downstream as {{nodeId.data.path}}. The exact response shape is documented on the upstream Upstash API reference.
GET /redis/database/{id}
Get Redis database details
| Detail | Value |
|---|---|
| Operation ID | database.getRedisDatabase |
| Method | GET |
| Path | /redis/database/{id} |
Parameters
No parameters.
Using this endpoint in a workflow
- Add an API Call node to your workflow.
- Pick your Upstash connection from the Connection dropdown.
- In the Operation dropdown, select
database.getRedisDatabase. - Fill in the parameter fields that appear. Use
{{...}}to reference upstream values.
What it returns
The API Call node writes the response to the workflow context:
{
status: 200,
success: true,
data: { ...response body from the API... },
latencyMs: 142
}Reference response fields downstream as {{nodeId.data.path}}. The exact response shape is documented on the upstream Upstash API reference.
DELETE /redis/database/{id}
Delete a Redis database
| Detail | Value |
|---|---|
| Operation ID | database.deleteRedisDatabase |
| Method | DELETE |
| Path | /redis/database/{id} |
Parameters
No parameters.
Using this endpoint in a workflow
- Add an API Call node to your workflow.
- Pick your Upstash connection from the Connection dropdown.
- In the Operation dropdown, select
database.deleteRedisDatabase. - Fill in the parameter fields that appear. Use
{{...}}to reference upstream values.
What it returns
The API Call node writes the response to the workflow context:
{
status: 200,
success: true,
data: { ...response body from the API... },
latencyMs: 142
}Reference response fields downstream as {{nodeId.data.path}}. The exact response shape is documented on the upstream Upstash API reference.
GET /redis/database/{id}/stats
Get database statistics
| Detail | Value |
|---|---|
| Operation ID | database.getRedisDatabaseStats |
| Method | GET |
| Path | /redis/database/{id}/stats |
Parameters
No parameters.
Using this endpoint in a workflow
- Add an API Call node to your workflow.
- Pick your Upstash connection from the Connection dropdown.
- In the Operation dropdown, select
database.getRedisDatabaseStats. - Fill in the parameter fields that appear. Use
{{...}}to reference upstream values.
What it returns
The API Call node writes the response to the workflow context:
{
status: 200,
success: true,
data: { ...response body from the API... },
latencyMs: 142
}Reference response fields downstream as {{nodeId.data.path}}. The exact response shape is documented on the upstream Upstash API reference.
GET /kafka/clusters
List Kafka clusters
| Detail | Value |
|---|---|
| Operation ID | database.listKafkaClusters |
| Method | GET |
| Path | /kafka/clusters |
Parameters
No parameters.
Using this endpoint in a workflow
- Add an API Call node to your workflow.
- Pick your Upstash connection from the Connection dropdown.
- In the Operation dropdown, select
database.listKafkaClusters. - Fill in the parameter fields that appear. Use
{{...}}to reference upstream values.
What it returns
The API Call node writes the response to the workflow context:
{
status: 200,
success: true,
data: { ...response body from the API... },
latencyMs: 142
}Reference response fields downstream as {{nodeId.data.path}}. The exact response shape is documented on the upstream Upstash API reference.
POST /kafka/clusters
Create a Kafka cluster
| Detail | Value |
|---|---|
| Operation ID | database.createKafkaCluster |
| Method | POST |
| Path | /kafka/clusters |
Parameters
No parameters.
Using this endpoint in a workflow
- Add an API Call node to your workflow.
- Pick your Upstash connection from the Connection dropdown.
- In the Operation dropdown, select
database.createKafkaCluster. - Fill in the parameter fields that appear. Use
{{...}}to reference upstream values.
What it returns
The API Call node writes the response to the workflow context:
{
status: 200,
success: true,
data: { ...response body from the API... },
latencyMs: 142
}Reference response fields downstream as {{nodeId.data.path}}. The exact response shape is documented on the upstream Upstash API reference.
POST /kafka/topic
Create a Kafka topic
| Detail | Value |
|---|---|
| Operation ID | database.createKafkaTopic |
| Method | POST |
| Path | /kafka/topic |
Parameters
No parameters.
Using this endpoint in a workflow
- Add an API Call node to your workflow.
- Pick your Upstash connection from the Connection dropdown.
- In the Operation dropdown, select
database.createKafkaTopic. - Fill in the parameter fields that appear. Use
{{...}}to reference upstream values.
What it returns
The API Call node writes the response to the workflow context:
{
status: 200,
success: true,
data: { ...response body from the API... },
latencyMs: 142
}Reference response fields downstream as {{nodeId.data.path}}. The exact response shape is documented on the upstream Upstash API reference.