Package Classes (1.10.1)

Datastream service

Datastream service

A pager for iterating through fetch_static_ips requests.

This class thinly wraps an initial FetchStaticIpsResponse object, and provides an __aiter__ method to iterate through its static_ips field.

If there are more pages, the __aiter__ method will make additional FetchStaticIps requests and continue to iterate through the static_ips field on the corresponding responses.

All the usual FetchStaticIpsResponse attributes are available on the pager. If multiple requests are made, only the most recent response is retained, and thus used for attribute lookup.

A pager for iterating through fetch_static_ips requests.

This class thinly wraps an initial FetchStaticIpsResponse object, and provides an __iter__ method to iterate through its static_ips field.

If there are more pages, the __iter__ method will make additional FetchStaticIps requests and continue to iterate through the static_ips field on the corresponding responses.

All the usual FetchStaticIpsResponse attributes are available on the pager. If multiple requests are made, only the most recent response is retained, and thus used for attribute lookup.

A pager for iterating through list_connection_profiles requests.

This class thinly wraps an initial ListConnectionProfilesResponse object, and provides an __aiter__ method to iterate through its connection_profiles field.

If there are more pages, the __aiter__ method will make additional ListConnectionProfiles requests and continue to iterate through the connection_profiles field on the corresponding responses.

All the usual ListConnectionProfilesResponse attributes are available on the pager. If multiple requests are made, only the most recent response is retained, and thus used for attribute lookup.

A pager for iterating through list_connection_profiles requests.

This class thinly wraps an initial ListConnectionProfilesResponse object, and provides an __iter__ method to iterate through its connection_profiles field.

If there are more pages, the __iter__ method will make additional ListConnectionProfiles requests and continue to iterate through the connection_profiles field on the corresponding responses.

All the usual ListConnectionProfilesResponse attributes are available on the pager. If multiple requests are made, only the most recent response is retained, and thus used for attribute lookup.

A pager for iterating through list_private_connections requests.

This class thinly wraps an initial ListPrivateConnectionsResponse object, and provides an __aiter__ method to iterate through its private_connections field.

If there are more pages, the __aiter__ method will make additional ListPrivateConnections requests and continue to iterate through the private_connections field on the corresponding responses.

All the usual ListPrivateConnectionsResponse attributes are available on the pager. If multiple requests are made, only the most recent response is retained, and thus used for attribute lookup.

A pager for iterating through list_private_connections requests.

This class thinly wraps an initial ListPrivateConnectionsResponse object, and provides an __iter__ method to iterate through its private_connections field.

If there are more pages, the __iter__ method will make additional ListPrivateConnections requests and continue to iterate through the private_connections field on the corresponding responses.

All the usual ListPrivateConnectionsResponse attributes are available on the pager. If multiple requests are made, only the most recent response is retained, and thus used for attribute lookup.

A pager for iterating through list_routes requests.

This class thinly wraps an initial ListRoutesResponse object, and provides an __aiter__ method to iterate through its routes field.

If there are more pages, the __aiter__ method will make additional ListRoutes requests and continue to iterate through the routes field on the corresponding responses.

All the usual ListRoutesResponse attributes are available on the pager. If multiple requests are made, only the most recent response is retained, and thus used for attribute lookup.

A pager for iterating through list_routes requests.

This class thinly wraps an initial ListRoutesResponse object, and provides an __iter__ method to iterate through its routes field.

If there are more pages, the __iter__ method will make additional ListRoutes requests and continue to iterate through the routes field on the corresponding responses.

All the usual ListRoutesResponse attributes are available on the pager. If multiple requests are made, only the most recent response is retained, and thus used for attribute lookup.

A pager for iterating through list_stream_objects requests.

This class thinly wraps an initial ListStreamObjectsResponse object, and provides an __aiter__ method to iterate through its stream_objects field.

If there are more pages, the __aiter__ method will make additional ListStreamObjects requests and continue to iterate through the stream_objects field on the corresponding responses.

All the usual ListStreamObjectsResponse attributes are available on the pager. If multiple requests are made, only the most recent response is retained, and thus used for attribute lookup.

A pager for iterating through list_stream_objects requests.

This class thinly wraps an initial ListStreamObjectsResponse object, and provides an __iter__ method to iterate through its stream_objects field.

If there are more pages, the __iter__ method will make additional ListStreamObjects requests and continue to iterate through the stream_objects field on the corresponding responses.

All the usual ListStreamObjectsResponse attributes are available on the pager. If multiple requests are made, only the most recent response is retained, and thus used for attribute lookup.

A pager for iterating through list_streams requests.

This class thinly wraps an initial ListStreamsResponse object, and provides an __aiter__ method to iterate through its streams field.

If there are more pages, the __aiter__ method will make additional ListStreams requests and continue to iterate through the streams field on the corresponding responses.

All the usual ListStreamsResponse attributes are available on the pager. If multiple requests are made, only the most recent response is retained, and thus used for attribute lookup.

A pager for iterating through list_streams requests.

This class thinly wraps an initial ListStreamsResponse object, and provides an __iter__ method to iterate through its streams field.

If there are more pages, the __iter__ method will make additional ListStreams requests and continue to iterate through the streams field on the corresponding responses.

All the usual ListStreamsResponse attributes are available on the pager. If multiple requests are made, only the most recent response is retained, and thus used for attribute lookup.

AVRO file format configuration.

Represents a backfill job on a specific stream object.

State of the stream object's backfill job.

Triggering reason for a backfill job.

BigQuery destination configuration

This message has oneof_ fields (mutually exclusive fields). For each oneof, at most one member field can be set at the same time. Setting any member of the oneof automatically clears all other members.

.. _oneof: https://proto-plus-python.readthedocs.io/en/stable/fields.html#oneofs-mutually-exclusive-fields

A single target dataset to which all data will be streamed.

Destination datasets are created so that hierarchy of the destination data objects matches the source hierarchy.

Dataset template used for dynamic dataset creation.

BigQuery warehouse profile.

A set of reusable connection configurations to be used as a source or destination for a stream.

This message has oneof_ fields (mutually exclusive fields). For each oneof, at most one member field can be set at the same time. Setting any member of the oneof automatically clears all other members.

.. _oneof: https://proto-plus-python.readthedocs.io/en/stable/fields.html#oneofs-mutually-exclusive-fields

The abstract base class for a message.

Request message for creating a connection profile.

Request for creating a private connection.

Route creation request.

Request message for creating a stream.

Request message for deleting a connection profile.

Request to delete a private connection.

Route deletion request.

Request message for deleting a stream.

The configuration of the stream destination.

This message has oneof_ fields (mutually exclusive fields). For each oneof, at most one member field can be set at the same time. Setting any member of the oneof automatically clears all other members.

.. _oneof: https://proto-plus-python.readthedocs.io/en/stable/fields.html#oneofs-mutually-exclusive-fields

Request message for 'discover' ConnectionProfile request.

This message has oneof_ fields (mutually exclusive fields). For each oneof, at most one member field can be set at the same time. Setting any member of the oneof automatically clears all other members.

.. _oneof: https://proto-plus-python.readthedocs.io/en/stable/fields.html#oneofs-mutually-exclusive-fields

Response from a discover request.

This message has oneof_ fields (mutually exclusive fields). For each oneof, at most one member field can be set at the same time. Setting any member of the oneof automatically clears all other members.

.. _oneof: https://proto-plus-python.readthedocs.io/en/stable/fields.html#oneofs-mutually-exclusive-fields

Represent a user-facing Error.

The abstract base class for a message.

Request message for 'FetchStaticIps' request.

Response message for a 'FetchStaticIps' response.

Forward SSH Tunnel connectivity.

This message has oneof_ fields (mutually exclusive fields). For each oneof, at most one member field can be set at the same time. Setting any member of the oneof automatically clears all other members.

.. _oneof: https://proto-plus-python.readthedocs.io/en/stable/fields.html#oneofs-mutually-exclusive-fields

Google Cloud Storage destination configuration

This message has oneof_ fields (mutually exclusive fields). For each oneof, at most one member field can be set at the same time. Setting any member of the oneof automatically clears all other members.

.. _oneof: https://proto-plus-python.readthedocs.io/en/stable/fields.html#oneofs-mutually-exclusive-fields

Cloud Storage bucket profile.

Request message for getting a connection profile.

Request to get a private connection configuration.

Route get request.

Request for fetching a specific stream object.

Request message for getting a stream.

JSON file format configuration.

Json file compression.

Schema file format.

Request message for listing connection profiles.

Response message for listing connection profiles.

Request for listing private connections.

Response containing a list of private connection configurations.

Route list request.

Route list response.

Request for listing all objects for a specific stream.

Response containing the objects for a stream.

Request message for listing streams.

Response message for listing streams.

Request for looking up a specific stream object by its source object identifier.

MySQL Column.

MySQL database.

MySQL database profile.

MySQL database structure

MySQL source configuration

MySQL SSL configuration information.

MySQL table.

Represents the metadata of the long-running operation.

Oracle Column.

Oracle database profile.

The abstract base class for a message.

Oracle database structure.

Oracle schema.

Oracle data source configuration

This message has oneof_ fields (mutually exclusive fields). For each oneof, at most one member field can be set at the same time. Setting any member of the oneof automatically clears all other members.

.. _oneof: https://proto-plus-python.readthedocs.io/en/stable/fields.html#oneofs-mutually-exclusive-fields

Configuration to drop large object values.

Configuration to stream large object values.

Oracle table.

PostgreSQL Column.

PostgreSQL database profile.

PostgreSQL database structure.

PostgreSQL schema.

PostgreSQL data source configuration

PostgreSQL table.

The PrivateConnection resource is used to establish private connectivity between Datastream and a customer's network.

The abstract base class for a message.

Private Connection state.

Private Connectivity

The route resource is the child of the private connection resource, used for defining a route for a private connection.

The abstract base class for a message.

The configuration of the stream source.

This message has oneof_ fields (mutually exclusive fields). For each oneof, at most one member field can be set at the same time. Setting any member of the oneof automatically clears all other members.

.. _oneof: https://proto-plus-python.readthedocs.io/en/stable/fields.html#oneofs-mutually-exclusive-fields

Represents an identifier of an object in the data source.

This message has oneof_ fields (mutually exclusive fields). For each oneof, at most one member field can be set at the same time. Setting any member of the oneof automatically clears all other members.

.. _oneof: https://proto-plus-python.readthedocs.io/en/stable/fields.html#oneofs-mutually-exclusive-fields

Mysql data source object identifier.

Oracle data source object identifier.

PostgreSQL data source object identifier.

Request for manually initiating a backfill job for a specific stream object.

Response for manually initiating a backfill job for a specific stream object.

Static IP address connectivity. Used when the source database is configured to allow incoming connections from the Datastream public IP addresses for the region specified in the connection profile.

Request for manually stopping a running backfill job for a specific stream object.

Response for manually stop a backfill job for a specific stream object.

A resource representing streaming data from a source to a destination.

This message has oneof_ fields (mutually exclusive fields). For each oneof, at most one member field can be set at the same time. Setting any member of the oneof automatically clears all other members.

.. _oneof: https://proto-plus-python.readthedocs.io/en/stable/fields.html#oneofs-mutually-exclusive-fields

Backfill strategy to automatically backfill the Stream's objects. Specific objects can be excluded.

This message has oneof_ fields (mutually exclusive fields). For each oneof, at most one member field can be set at the same time. Setting any member of the oneof automatically clears all other members.

.. _oneof: https://proto-plus-python.readthedocs.io/en/stable/fields.html#oneofs-mutually-exclusive-fields

Backfill strategy to disable automatic backfill for the Stream's objects.

The abstract base class for a message.

Stream state.

    Updates are rejected on the resource in this
    state.
FAILED (5):
    The stream is experiencing an error that is
    preventing data from being streamed.
FAILED_PERMANENTLY (6):
    The stream has experienced a terminal
    failure.
STARTING (7):
    The stream is starting, but not yet running.
DRAINING (8):
    The Stream is no longer reading new events,
    but still writing events in the buffer.

A specific stream object (e.g a specific DB table).

Connection profile update message.

Request message for updating a stream.

A validation to perform on a stream.

Validation execution state.

Represent user-facing validation result message.

Validation message level.

The abstract base class for a message.

Contains the current validation results.

The VPC Peering configuration is used to create VPC peering between Datastream and the consumer's VPC.

Datastream service

Datastream service

A pager for iterating through fetch_static_ips requests.

This class thinly wraps an initial FetchStaticIpsResponse object, and provides an __aiter__ method to iterate through its static_ips field.

If there are more pages, the __aiter__ method will make additional FetchStaticIps requests and continue to iterate through the static_ips field on the corresponding responses.

All the usual FetchStaticIpsResponse attributes are available on the pager. If multiple requests are made, only the most recent response is retained, and thus used for attribute lookup.

A pager for iterating through fetch_static_ips requests.

This class thinly wraps an initial FetchStaticIpsResponse object, and provides an __iter__ method to iterate through its static_ips field.

If there are more pages, the __iter__ method will make additional FetchStaticIps requests and continue to iterate through the static_ips field on the corresponding responses.

All the usual FetchStaticIpsResponse attributes are available on the pager. If multiple requests are made, only the most recent response is retained, and thus used for attribute lookup.

A pager for iterating through list_connection_profiles requests.

This class thinly wraps an initial ListConnectionProfilesResponse object, and provides an __aiter__ method to iterate through its connection_profiles field.

If there are more pages, the __aiter__ method will make additional ListConnectionProfiles requests and continue to iterate through the connection_profiles field on the corresponding responses.

All the usual ListConnectionProfilesResponse attributes are available on the pager. If multiple requests are made, only the most recent response is retained, and thus used for attribute lookup.

A pager for iterating through list_connection_profiles requests.

This class thinly wraps an initial ListConnectionProfilesResponse object, and provides an __iter__ method to iterate through its connection_profiles field.

If there are more pages, the __iter__ method will make additional ListConnectionProfiles requests and continue to iterate through the connection_profiles field on the corresponding responses.

All the usual ListConnectionProfilesResponse attributes are available on the pager. If multiple requests are made, only the most recent response is retained, and thus used for attribute lookup.

A pager for iterating through list_private_connections requests.

This class thinly wraps an initial ListPrivateConnectionsResponse object, and provides an __aiter__ method to iterate through its private_connections field.

If there are more pages, the __aiter__ method will make additional ListPrivateConnections requests and continue to iterate through the private_connections field on the corresponding responses.

All the usual ListPrivateConnectionsResponse attributes are available on the pager. If multiple requests are made, only the most recent response is retained, and thus used for attribute lookup.

A pager for iterating through list_private_connections requests.

This class thinly wraps an initial ListPrivateConnectionsResponse object, and provides an __iter__ method to iterate through its private_connections field.

If there are more pages, the __iter__ method will make additional ListPrivateConnections requests and continue to iterate through the private_connections field on the corresponding responses.

All the usual ListPrivateConnectionsResponse attributes are available on the pager. If multiple requests are made, only the most recent response is retained, and thus used for attribute lookup.

A pager for iterating through list_routes requests.

This class thinly wraps an initial ListRoutesResponse object, and provides an __aiter__ method to iterate through its routes field.

If there are more pages, the __aiter__ method will make additional ListRoutes requests and continue to iterate through the routes field on the corresponding responses.

All the usual ListRoutesResponse attributes are available on the pager. If multiple requests are made, only the most recent response is retained, and thus used for attribute lookup.

A pager for iterating through list_routes requests.

This class thinly wraps an initial ListRoutesResponse object, and provides an __iter__ method to iterate through its routes field.

If there are more pages, the __iter__ method will make additional ListRoutes requests and continue to iterate through the routes field on the corresponding responses.

All the usual ListRoutesResponse attributes are available on the pager. If multiple requests are made, only the most recent response is retained, and thus used for attribute lookup.

A pager for iterating through list_streams requests.

This class thinly wraps an initial ListStreamsResponse object, and provides an __aiter__ method to iterate through its streams field.

If there are more pages, the __aiter__ method will make additional ListStreams requests and continue to iterate through the streams field on the corresponding responses.

All the usual ListStreamsResponse attributes are available on the pager. If multiple requests are made, only the most recent response is retained, and thus used for attribute lookup.

A pager for iterating through list_streams requests.

This class thinly wraps an initial ListStreamsResponse object, and provides an __iter__ method to iterate through its streams field.

If there are more pages, the __iter__ method will make additional ListStreams requests and continue to iterate through the streams field on the corresponding responses.

All the usual ListStreamsResponse attributes are available on the pager. If multiple requests are made, only the most recent response is retained, and thus used for attribute lookup.

AVRO file format configuration.

This message has oneof_ fields (mutually exclusive fields). For each oneof, at most one member field can be set at the same time. Setting any member of the oneof automatically clears all other members.

.. _oneof: https://proto-plus-python.readthedocs.io/en/stable/fields.html#oneofs-mutually-exclusive-fields

The abstract base class for a message.

route creation request

route deletion request

The configuration of the stream destination.

.. _oneof: https://proto-plus-python.readthedocs.io/en/stable/fields.html#oneofs-mutually-exclusive-fields

Request message for 'discover' ConnectionProfile request.

This message has oneof_ fields (mutually exclusive fields). For each oneof, at most one member field can be set at the same time. Setting any member of the oneof automatically clears all other members.

.. _oneof: https://proto-plus-python.readthedocs.io/en/stable/fields.html#oneofs-mutually-exclusive-fields

This message has oneof_ fields (mutually exclusive fields). For each oneof, at most one member field can be set at the same time. Setting any member of the oneof automatically clears all other members.

.. _oneof: https://proto-plus-python.readthedocs.io/en/stable/fields.html#oneofs-mutually-exclusive-fields

Represent a user-facing Error.

The abstract base class for a message.

Request message for 'FetchErrors' request.

Response message for a 'FetchErrors' response.

Request message for 'FetchStaticIps' request.

Response message for a 'FetchStaticIps' response.

Forward SSH Tunnel connectivity.

This message has oneof_ fields (mutually exclusive fields). For each oneof, at most one member field can be set at the same time. Setting any member of the oneof automatically clears all other members.

.. _oneof: https://proto-plus-python.readthedocs.io/en/stable/fields.html#oneofs-mutually-exclusive-fields

Google Cloud Storage destination configuration

This message has oneof_ fields (mutually exclusive fields). For each oneof, at most one member field can be set at the same time. Setting any member of the oneof automatically clears all other members.

.. _oneof: https://proto-plus-python.readthedocs.io/en/stable/fields.html#oneofs-mutually-exclusive-fields

File format in Cloud Storage.

Cloud Storage bucket profile.

route get request

JSON file format configuration.

Json file compression.

route list request

route list response

MySQL Column.

MySQL database.

MySQL database profile.

MySQL database structure

MySQL source configuration

MySQL SSL configuration information.

MySQL table.

No connectivity settings.

Represents the metadata of the long-running operation.

Oracle Column.

Oracle database profile.

The abstract base class for a message.

Oracle database structure.

Oracle schema.

Oracle data source configuration

Oracle table.

The PrivateConnection resource is used to establish private connectivity between Datastream and a customer's network.

The abstract base class for a message.

Private Connection state.

Private Connectivity

The Route resource is the child of the PrivateConnection resource. It used to define a route for a PrivateConnection setup.

The abstract base class for a message.

Schema file format.

The configuration of the stream source.

This message has oneof_ fields (mutually exclusive fields). For each oneof, at most one member field can be set at the same time. Setting any member of the oneof automatically clears all other members.

.. _oneof: https://proto-plus-python.readthedocs.io/en/stable/fields.html#oneofs-mutually-exclusive-fields

Static IP address connectivity.

This message has oneof_ fields (mutually exclusive fields). For each oneof, at most one member field can be set at the same time. Setting any member of the oneof automatically clears all other members.

.. _oneof: https://proto-plus-python.readthedocs.io/en/stable/fields.html#oneofs-mutually-exclusive-fields

Backfill strategy to automatically backfill the Stream's objects. Specific objects can be excluded.

This message has oneof_ fields (mutually exclusive fields). For each oneof, at most one member field can be set at the same time. Setting any member of the oneof automatically clears all other members.

.. _oneof: https://proto-plus-python.readthedocs.io/en/stable/fields.html#oneofs-mutually-exclusive-fields

Backfill strategy to disable automatic backfill for the Stream's objects.

The abstract base class for a message.

Stream state.

    Updates are rejected on the resource in this
    state.
FAILED (5):
    The stream is experiencing an error that is
    preventing data from being streamed.
FAILED_PERMANENTLY (6):
    The stream has experienced a terminal
    failure.
STARTING (7):
    The stream is starting, but not yet running.
DRAINING (8):
    The Stream is no longer reading new events,
    but still writing events in the buffer.

Validation execution status.

Represent user-facing validation result message.

Validation message level.

The abstract base class for a message.

Contains the current validation results.

The VPC Peering configuration is used to create VPC peering between Datastream and the consumer's VPC.

API documentation for datastream_v1.services.datastream.pagers module.

API documentation for datastream_v1alpha1.services.datastream.pagers module.