Search + K

Command Palette

Search for a command to run...

Sign In

Return One Stream Processor

GET /api/atlas/v2/groups/{groupId}/streams/{tenantName}/processor/{processorName}
Copy endpoint
https://cloud.mongodb.com

Get one Stream Processor within the specified stream workspace. To use this resource, the requesting Service Account or API Key must have the Project Owner role or Project Stream Processing Owner role.

Parameters

path Path Parameters

Name Type
groupId required

Unique 24-hexadecimal digit string that identifies your project. Use the /groups endpoint to retrieve all projects to which the authenticated user has access.

NOTE: Groups and projects are synonymous terms. Your group id is the same as your project id. For existing groups, your group/project id remains the same. The resource and corresponding endpoints use the term groups.

string
tenantName required

Label that identifies the stream workspace.

string
processorName required

Label that identifies the stream processor.

string

query Query Parameters

Name Type
envelope

Flag that indicates whether Application wraps the response in an envelope JSON object. Some API clients cannot access the HTTP response headers or status code. To remediate this, set envelope=true in the query. Endpoints that return a list of results use the results object as an envelope. Application adds the status parameter to the response body.

boolean
pretty

Flag that indicates whether the response body should be in the prettyprint format.

boolean

Responses

200 application/vnd.atlas.2024-05-30+json

OK

interface StreamsProcessorWithStats {
_id: string;
links?: readonly Link
interface Link {
href?: string;
rel?: string;
}
[]
;
name: string;
options?: StreamsOptions

Optional configuration for the stream processor.

interface StreamsOptions {
dlq?: StreamsDLQ;
links?: readonly Link[];
}
;
pipeline: readonly { }[];
state: string;
stats?: { };
tier?: "SP50" | "SP30" | "SP10" | "SP5" | "SP2";
}

Client Errors

400 application/json

Bad Request.

interface ApiError {
badRequestDetail?: BadRequestDetail

Bad request detail.

interface BadRequestDetail {
fields?: FieldViolation[];
}
;
detail?: string;
error: number;
errorCode: string;
parameters?: readonly {}[];
reason?: string;
}
401 application/json

Unauthorized.

interface ApiError {
badRequestDetail?: BadRequestDetail

Bad request detail.

interface BadRequestDetail {
fields?: FieldViolation[];
}
;
detail?: string;
error: number;
errorCode: string;
parameters?: readonly {}[];
reason?: string;
}
403 application/json

Forbidden.

interface ApiError {
badRequestDetail?: BadRequestDetail

Bad request detail.

interface BadRequestDetail {
fields?: FieldViolation[];
}
;
detail?: string;
error: number;
errorCode: string;
parameters?: readonly {}[];
reason?: string;
}
404 application/json

Not Found.

interface ApiError {
badRequestDetail?: BadRequestDetail

Bad request detail.

interface BadRequestDetail {
fields?: FieldViolation[];
}
;
detail?: string;
error: number;
errorCode: string;
parameters?: readonly {}[];
reason?: string;
}

Server Errors

500 application/json

Internal Server Error.

interface ApiError {
badRequestDetail?: BadRequestDetail

Bad request detail.

interface BadRequestDetail {
fields?: FieldViolation[];
}
;
detail?: string;
error: number;
errorCode: string;
parameters?: readonly {}[];
reason?: string;
}