# com.googleapis.datastream/mcp (remote · datastream.googleapis.com)

Interact with your Google Cloud Datastream resources using natural language commands.

- Trust score: 60/100 (medium)
- Change this week: +3
- Registry status: active
- Liveness: live
- Owner verified: no
- Last scored: 2026-08-03

## Components

- remote · `datastream.googleapis.com`: 60/100 (this document), [markdown](https://verifymcp.io/servers/com-googleapis-datastream-mcp/datastream.md), [page](https://verifymcp.io/servers/com-googleapis-datastream-mcp/datastream)

## Channel facts

- Endpoint: `https://datastream.googleapis.com/mcp`
- Transports: `streamable-http`
- Auth: `none`
- Version: `1.0.0`

## Trust breakdown

How this component scores in each security and reliability category. Every signal is checked automatically against the live server, and we only credit what we can confirm. Scores are 0–100 per category. Scoring method: https://verifymcp.io/docs/scoring (what has changed: https://verifymcp.io/docs/scoring/changelog)

Scored 2026-08-03.

- **Endpoint Security**: 46/100
  - The endpoint's TLS certificate is valid, in date, and uses a strong key.
  - Authorisation check failed: no authorisation is required to call this server, and it exposes a tool marked destructive (delete_stream).
  - HTTPS not yet verified: we couldn't determine whether a plaintext access path exists.
  - HSTS check failed: the Strict-Transport-Security header is absent.
  - DNSSEC check failed: this domain isn't protected by DNSSEC.
- **Transport & Reachability**: 100/100
  - Verified streamable-http transport via a live MCP handshake.
- **Schema Quality & AI Usability**: 61/100
  - AI-judged instruction clarity (excellent).
  - Context-footprint check failed: tool/resource definitions use about 2517 tokens (~251/item across 10 items; 10 tools + 0 resources), over budget; trim descriptions and params.
  - Usage-examples check failed: none of the tools include examples.
- **Stability & Change Management**: 27/100
  - Stability observed for 8 of 30 days with no destabilising changes; credit accrues until the full window elapses.
- **Tool Coverage**: 100/100
  - 100% of tools have a non-trivial description (not blank, and not just the tool's name).
  - 100% of tool parameters carry a description.
  - Structured output schemas are declared (100% of tools); any adoption earns full credit.
- **Capabilities**: 100/100
  - Implements a supported MCP spec version (2025-11-25); the latest is 2026-07-28.

## Install

### Claude

```bash
claude mcp add --transport http com-googleapis-datastream-mcp https://datastream.googleapis.com/mcp
```

### Codex

```toml
[mcp_servers.com-googleapis-datastream-mcp]
url = "https://datastream.googleapis.com/mcp"
```

### opencode

```json
{
  "$schema": "https://opencode.ai/config.json",
  "mcp": {
    "com-googleapis-datastream-mcp": {
      "type": "remote",
      "url": "https://datastream.googleapis.com/mcp",
      "enabled": true
    }
  }
}
```

### OpenClaw

```bash
openclaw mcp add com-googleapis-datastream-mcp --url https://datastream.googleapis.com/mcp --transport streamable-http
```

### Hermes

```yaml
mcp_servers:
  com-googleapis-datastream-mcp:
    url: "https://datastream.googleapis.com/mcp"
```

### Other

```json
{
  "mcpServers": {
    "com-googleapis-datastream-mcp": {
      "type": "http",
      "url": "https://datastream.googleapis.com/mcp"
    }
  }
}
```

The mcpServers block is a cross-client convention. Remote transports vary, so check your client's docs.

## Changelog

Every change recorded for this component, newest first. Days that predate change tracking, or that we cannot explain, say so: "we were watching and nothing happened" and "we were not watching" are different claims.

### 2026-08-03 (score 60, +1)

No change was recorded against any check on this day. Stability & Change Management went from 23 to 27. That category is still filling its 30-day observation window: 7 days of observed history at the previous scan, 8 at this one. The score rises as the window fills, whether or not the server changes.

### 2026-08-01 (score 59, +1)

No change was recorded against any check on this day. Stability & Change Management went from 17 to 20. That category is still filling its 30-day observation window: 5 days of observed history at the previous scan, 6 at this one. The score rises as the window fills, whether or not the server changes.

### 2026-07-31 (score 58, −1)

- [functional] We updated how we score, so this day's move reflects our rubric, not a change to the server

### 2026-07-29 (score 59, +1)

No change was recorded against any check on this day. Stability & Change Management went from 7 to 10. That category is still filling its 30-day observation window: 2 days of observed history at the previous scan, 3 at this one. The score rises as the window fills, whether or not the server changes.

### 2026-07-28 (score 58, +1)

No change was recorded against any check on this day. Stability & Change Management went from 3 to 7. That category is still filling its 30-day observation window: 1 days of observed history at the previous scan, 2 at this one. The score rises as the window fills, whether or not the server changes.

### 2026-07-27 (score 57, 0)

- [functional] We updated how we score, so this day's move reflects our rubric, not a change to the server

### 2026-07-26 (score 57)

First indexed and scored.

## MCP tools (10)

### `get_operation` (~233 tokens)

Gets the status of a long-running operation.

\***Usage***
Some tools (for example, `run_stream`) return a long-running operation.
You can use this tool to get the status of the operation. It can be called repeatedly until
the operation is complete.

\**Parameters**
\*   `name`: The name of the operation to get.
    * `name` should be the name returned by the tool that initiated the operation.
    * `name` should be in the format of:
      `projects/{project}/locations/{location}/operations/{operation}`.

\**Returns**
\*   An `Operation` object that contains the status of the operation.
\*   If the operation is not complete, the response will be empty. Do not check more than
    every ten seconds.
\*   If the operation is complete, the response will contain either:
    * A `response` field that contains the result of the operation and indicates that it was
      successful.
    * A `error` field that indicates any errors that occurred during the operation.

Input parameters:

- `name` (string): The name of the operation resource.

Output parameters:

- `done` (boolean): If the value is `false`, it means the operation is still in progress. If `true`, the operation is completed, and either `error` or `response` is available.
- `error`: The error result of the operation in case of failure or cancellation.
- `metadata` (object): Service-specific metadata associated with the operation. It typically contains progress information and common metadata such as create time. Some services might not provide such metadata. Any method…
- `name` (string): The server-assigned name, which is only unique within the same service that originally returns it. If you use the default HTTP mapping, the `name` should be a resource name ending with `operations/{u…
- `response` (object): The normal, successful response of the operation. If the original method returns no data on success, such as `Delete`, the response is `google.protobuf.Empty`. If the original method is standard `Get…

### `list_connection_profiles` (~503 tokens)

Lists connection profiles in a given project and location.

For example:
{
  parent: "projects/my-project/locations/us-central1"
  create_time_after: 2025-10-02T10:15:33Z
  create_time_before: 2025-10-03T00:00:00Z
  display_name: bookstore
  page_size: 100
}
will return up to 100 connection profiles in `projects/my-project/locations/us-central1`
that were created on or after 2025-10-02T10:15:33 UTC and before 2025-10-03T00:00:00 UTC,
and have "bookstore" in their display name.

Input parameters:

- `createTimeAfter` (string): Optional. Use to get connection profiles that were created on or after the provided date/time, formatted as RFC-3339. Common Examples: 2023-09-24T15:30:00Z or 2023-09-24T15:30:00.000+09:00.
- `createTimeBefore` (string): Optional. Use to get connection profiles that were created before the provided date/time, formatted as RFC-3339. Common Examples: 2023-09-24T15:30:00Z or 2023-09-24T15:30:00.000+09:00.
- `displayName` (string): Optional. Use to get connection profiles whose display name contains the provided name.
- `pageSize` (integer): Optional. Use to limit the number of connection profiles returned. Valid values are between 1 and 1000 inclusive. Defaults to 1000 if not provided or outside of the valid range. Note that due to filt…
- `pageToken` (string): Optional. A page token, received from a previous `list_connection_profiles` call. Provide this to retrieve the subsequent page. When paginating, all other parameters provided to `list_connection_prof…
- `parent` (string, required): Required. The parent that owns the collection of connection profiles. Must be in the format `projects/*/locations/*`. For example: 'projects/my-project/locations/us-central1'

Output parameters:

- `connectionProfiles` (array): List of connection profiles.
- `nextPageToken` (string): A token, which can be sent as `page_token` to retrieve the next page. If this field is omitted, there are no subsequent pages.
- `unreachable` (array): Locations that could not be reached.

### `list_streams` (~548 tokens)

Lists streams in a given project and location.

For example:
{
  parent: "projects/my-project/locations/us-central1"
  create_time_after: 2025-10-02T10:15:33Z
  create_time_before: 2025-10-03T00:00:00Z
  display_name: bookstore
  page_size: 100
  running: true
}
will return up to 100 running streams in `projects/my-project/locations/us-central1` that
were created on or after 2025-10-02T10:15:33 UTC and before 2025-10-03T00:00:00 UTC,
and have "bookstore" in their display name.

Input parameters:

- `createTimeAfter` (string): Optional. Use to get streams that were created on or after the provided date/time, formatted as RFC-3339. Common Examples: 2023-09-24T15:30:00Z or 2023-09-24T15:30:00.000+09:00.
- `createTimeBefore` (string): Optional. Use to get streams that were created before the provided date/time, formatted as RFC-3339. Common Examples: 2023-09-24T15:30:00Z or 2023-09-24T15:30:00.000+09:00.
- `displayName` (string): Optional. Use to get streams whose display name contains the provided name.
- `failed` (boolean): Optional. Use to get streams that are currently in state FAILED or FAILED_PERMANENTLY.
- `pageSize` (integer): Optional. Use to limit the number of streams returned. Valid values are between 1 and 1000 inclusive. Defaults to 1000 if not provided or outside of the valid range. Note that due to filtering, it is…
- `pageToken` (string): Optional. A page token, received from a previous `list_streams` call. Provide this to retrieve the subsequent page. When paginating, all other parameters provided to `list_streams` must match the cal…
- `parent` (string, required): Required. The parent that owns the collection of streams. Must be in the format `projects/*/locations/*`. For example: 'projects/my-project/locations/us-central1'
- `running` (boolean): Optional. Use to get streams that are currently in state RUNNING.

Output parameters:

- `nextPageToken` (string): A token, which can be sent as `page_token` to retrieve the next page. If this field is omitted, there are no subsequent pages.
- `streams` (array): List of streams
- `unreachable` (array): Locations that could not be reached.

### `get_stream` (~87 tokens)

Get details of the stream specified by the provided resource 'name' parameter.
\* The resource 'name' parameter is in the form:
  'projects/{project name}/locations/{location}/streams/{stream name}',
  for example: 'projects/my-project/locations/us-central1/streams/my-streams'.

Input parameters:

- `name` (string, required): Required. The name of the stream resource to get.

Output parameters:

- `backfillAll`: Automatically backfill objects included in the stream source configuration. Specific objects can be excluded.
- `backfillNone`: Do not automatically backfill any objects.
- `createTime` (string): Output only. The creation time of the stream.
- `customerManagedEncryptionKey` (string): Immutable. A reference to a KMS encryption key. If provided, it will be used to encrypt the data. If left blank, data will be encrypted using an internal Stream-specific encryption key provisioned th…
- `destinationConfig`: Required. Destination connection profile configuration.
- `displayName` (string): Required. Display name.
- `errors` (array): Output only. Errors on the Stream.
- `labels` (object): Labels.
- `lastRecoveryTime` (string): Output only. If the stream was recovered, the time of the last recovery. Note: This field is currently experimental.
- `name` (string): Output only. Identifier. The stream's name.
- `ruleSets` (array): Optional. Rule sets to apply to the stream.
- `satisfiesPzi` (boolean): Output only. Reserved for future use.
- `satisfiesPzs` (boolean): Output only. Reserved for future use.
- `sourceConfig`: Required. Source connection profile configuration.
- `state` (string): The state of the stream.
- `updateTime` (string): Output only. The last update time of the stream.

### `run_stream` (~241 tokens)

Starts an already created stream, specified by the provided resource 'name' parameter.

\**Parameters**
\*   'name': The resource name of the stream to start.
    * 'name' should be in the format of:
      'projects/{project name}/locations/{location}/streams/{stream name}',
      for example: 'projects/my-project/locations/us-central1/streams/my-streams'.
\*   'force': Whether to run the stream without running prior configuration verification.
    The default is 'false'.

\**Returns**
\*   This tool returns a long-running operation. Use the 'get_operation' tool with the
    returned operation name to poll its status until it completes. Operation may take
    several minutes; do not check more often than every ten seconds.

Input parameters:

- `cdcStrategy`: Optional. The CDC strategy of the stream. If not set, the system's default value will be used.
- `force` (boolean): Optional. Update the stream without validating it.
- `name` (string, required): Required. Name of the stream resource to start, in the format: projects/{project_id}/locations/{location}/streams/{stream_name}

Output parameters:

- `done` (boolean): If the value is `false`, it means the operation is still in progress. If `true`, the operation is completed, and either `error` or `response` is available.
- `error`: The error result of the operation in case of failure or cancellation.
- `metadata` (object): Service-specific metadata associated with the operation. It typically contains progress information and common metadata such as create time. Some services might not provide such metadata. Any method…
- `name` (string): The server-assigned name, which is only unique within the same service that originally returns it. If you use the default HTTP mapping, the `name` should be a resource name ending with `operations/{u…
- `response` (object): The normal, successful response of the operation. If the original method returns no data on success, such as `Delete`, the response is `google.protobuf.Empty`. If the original method is standard `Get…

### `delete_stream` (~296 tokens)

Deletes a stream, specified by the provided resource 'name' parameter.
\* The resource 'name' parameter is in the form:
  'projects/{project name}/locations/{location}/streams/{stream name}',
  for example: 'projects/my-project/locations/us-central1/streams/my-streams'.
\* This tool returns a long-running operation. Use the 'get_operation' tool with the
  returned operation name to poll its status until it completes. Operation may take
  several minutes; do not check more often than every ten seconds.

Input parameters:

- `name` (string, required): Required. The name of the stream resource to delete.
- `requestId` (string): Optional. A request ID to identify requests. Specify a unique request ID so that if you must retry your request, the server will know to ignore the request if it has already been completed. The serve…

Output parameters:

- `done` (boolean): If the value is `false`, it means the operation is still in progress. If `true`, the operation is completed, and either `error` or `response` is available.
- `error`: The error result of the operation in case of failure or cancellation.
- `metadata` (object): Service-specific metadata associated with the operation. It typically contains progress information and common metadata such as create time. Some services might not provide such metadata. Any method…
- `name` (string): The server-assigned name, which is only unique within the same service that originally returns it. If you use the default HTTP mapping, the `name` should be a resource name ending with `operations/{u…
- `response` (object): The normal, successful response of the operation. If the original method returns no data on success, such as `Delete`, the response is `google.protobuf.Empty`. If the original method is standard `Get…

### `list_stream_objects` (~206 tokens)

Lists stream objects in a given stream.
\* Parent parameter is in the form 'projects/{project name}/locations/{location}/streams/{stream name}',
for example:
'projects/my-project/locations/us-central1/streams/my-stream'.
\* Not all the details of the stream objects are returned.
\* To get the full details of a specific stream object, use the 'get_stream_object' tool.

Input parameters:

- `pageSize` (integer): Optional. Maximum number of objects to return. Default is 50. The maximum value is 1000; values above 1000 will be coerced to 1000.
- `pageToken` (string): Optional. Page token received from a previous `ListStreamObjectsRequest` call. Provide this to retrieve the subsequent page. When paginating, all other parameters provided to `ListStreamObjectsReques…
- `parent` (string, required): Required. The parent stream that owns the collection of objects.

Output parameters:

- `nextPageToken` (string): A token, which can be sent as `page_token` to retrieve the next page.
- `streamObjects` (array): List of stream objects.

### `get_stream_object` (~100 tokens)

Get details of the stream object specified by the provided resource 'name' parameter.
\* The resource 'name' parameter is in the form:
  'projects/{project name}/locations/{location}/streams/{stream name}/objects/{stream object name}',
  for example: 'projects/my-project/locations/us-central1/streams/my-stream/objects/my-stream-object'.

Input parameters:

- `name` (string, required): Required. The name of the stream object resource to get.

Output parameters:

- `backfillJob`: The latest backfill job that was initiated for the stream object.
- `createTime` (string): Output only. The creation time of the object.
- `customizationRules` (array): Output only. The customization rules for the object. These rules are derived from the parent Stream's `rule_sets` and represent the intended configuration for the object.
- `displayName` (string): Required. Display name.
- `errors` (array): Output only. Active errors on the object.
- `name` (string): Output only. Identifier. The object resource's name.
- `sourceObject`: The object identifier in the data source.
- `updateTime` (string): Output only. The last update time of the object.

### `lookup_stream_object` (~176 tokens)

Lookup a stream object by its source object identifier.
\**Parameters:**
\* The 'parent' parameter is the name of the stream in the form:
  'projects/{project name}/locations/{location}/streams/{stream name}',
  for example: 'projects/my-project/locations/us-central1/streams/my-stream'.
\* The 'source_object_identifier' parameter is the source database object identifier.
  Different source databases have different identifier formats. Examples:
  \* Oracle, PostgreSQL, SQL Server and Spanner databases the identifier is
    'schema' and 'table'.
  \* MySQL databases the identifier is 'database' and 'table'.

Input parameters:

- `parent` (string, required): Required. The parent stream that owns the collection of objects.
- `sourceObjectIdentifier` (required): Required. The source object identifier which maps to the stream object.

Output parameters:

- `backfillJob`: The latest backfill job that was initiated for the stream object.
- `createTime` (string): Output only. The creation time of the object.
- `customizationRules` (array): Output only. The customization rules for the object. These rules are derived from the parent Stream's `rule_sets` and represent the intended configuration for the object.
- `displayName` (string): Required. Display name.
- `errors` (array): Output only. Active errors on the object.
- `name` (string): Output only. Identifier. The object resource's name.
- `sourceObject`: The object identifier in the data source.
- `updateTime` (string): Output only. The last update time of the object.

### `list_static_ips` (~127 tokens)

Lists static IP addresses of the provided resource name that need to be allowlisted by the
customer when using the static-IP connectivity method.
Returns up to 100 IP addresses.
\* The resource 'name' parameter is in the form 'projects/{project name}/locations/{location}',
  for example: 'projects/my-project/locations/us-central1'.

Input parameters:

- `name` (string, required): Required. The resource name for the location for which static IPs should be returned. Must be in the format `projects/*/locations/*`. For example: 'projects/my-project/locations/us-central1'

Output parameters:

- `nextPageToken` (string): A token that can be sent as `page_token` to retrieve the next page. If this field is omitted, there are no subsequent pages.
- `staticIps` (array): list of static ips by account

## Diagnostics

Captured diagnostic sections: TLS, DNSSEC, Authorisation, Transports. The full working is on the page: https://verifymcp.io/servers/com-googleapis-datastream-mcp/datastream#diagnostics

## Score history

- 2026-08-03: 60
- 2026-08-02: 59
- 2026-08-01: 59
- 2026-07-31: 58
- 2026-07-30: 59
- 2026-07-29: 59
- 2026-07-28: 58
- 2026-07-27: 57
- 2026-07-26: 57

## Links

- Remote endpoint: https://datastream.googleapis.com/mcp
- Changelog RSS feed: https://verifymcp.io/servers/com-googleapis-datastream-mcp/datastream/changelog.xml
- Changelog JSON feed: https://verifymcp.io/servers/com-googleapis-datastream-mcp/datastream/changelog.json
- HTML version of this page: https://verifymcp.io/servers/com-googleapis-datastream-mcp/datastream