Close httplib2 connections.
Use this method to get details about a stream object.
list(parent, pageSize=None, pageToken=None, x__xgafv=None)
Use this method to list the objects of a specific stream.
Retrieves the next page of results.
lookup(parent, body=None, x__xgafv=None)
Use this method to look up a stream object by its source object identifier.
startBackfillJob(object, body=None, x__xgafv=None)
Use this method to start a backfill job for the specified stream object.
stopBackfillJob(object, body=None, x__xgafv=None)
Use this method to stop a backfill job for the specified stream object.
close()
Close httplib2 connections.
get(name, x__xgafv=None)
Use this method to get details about a stream object. Args: name: string, Required. The name of the stream object resource to get. (required) x__xgafv: string, V1 error format. Allowed values 1 - v1 error format 2 - v2 error format Returns: An object of the form: { # A specific stream object (e.g a specific DB table). "backfillJob": { # Represents a backfill job on a specific stream object. # The latest backfill job that was initiated for the stream object. "errors": [ # Output only. Errors which caused the backfill job to fail. { # Represent a user-facing Error. "details": { # Additional information about the error. "a_key": "A String", }, "errorTime": "A String", # The time when the error occurred. "errorUuid": "A String", # A unique identifier for this specific error, allowing it to be traced throughout the system in logs and API responses. "message": "A String", # A message containing more information about the error that occurred. "reason": "A String", # A title that explains the reason for the error. }, ], "lastEndTime": "A String", # Output only. Backfill job's end time. "lastStartTime": "A String", # Output only. Backfill job's start time. "state": "A String", # Output only. Backfill job state. "trigger": "A String", # Backfill job's triggering reason. }, "createTime": "A String", # Output only. The creation time of the object. "displayName": "A String", # Required. Display name. "errors": [ # Output only. Active errors on the object. { # Represent a user-facing Error. "details": { # Additional information about the error. "a_key": "A String", }, "errorTime": "A String", # The time when the error occurred. "errorUuid": "A String", # A unique identifier for this specific error, allowing it to be traced throughout the system in logs and API responses. "message": "A String", # A message containing more information about the error that occurred. "reason": "A String", # A title that explains the reason for the error. }, ], "name": "A String", # Output only. The object resource's name. "sourceObject": { # Represents an identifier of an object in the data source. # The object identifier in the data source. "mysqlIdentifier": { # Mysql data source object identifier. # Mysql data source object identifier. "database": "A String", # Required. The database name. "table": "A String", # Required. The table name. }, "oracleIdentifier": { # Oracle data source object identifier. # Oracle data source object identifier. "schema": "A String", # Required. The schema name. "table": "A String", # Required. The table name. }, "postgresqlIdentifier": { # PostgreSQL data source object identifier. # PostgreSQL data source object identifier. "schema": "A String", # Required. The schema name. "table": "A String", # Required. The table name. }, "sqlServerIdentifier": { # SQLServer data source object identifier. # SQLServer data source object identifier. "schema": "A String", # Required. The schema name. "table": "A String", # Required. The table name. }, }, "updateTime": "A String", # Output only. The last update time of the object. }
list(parent, pageSize=None, pageToken=None, x__xgafv=None)
Use this method to list the objects of a specific stream. Args: parent: string, Required. The parent stream that owns the collection of objects. (required) pageSize: integer, Maximum number of objects to return. Default is 50. The maximum value is 1000; values above 1000 will be coerced to 1000. pageToken: string, Page token received from a previous `ListStreamObjectsRequest` call. Provide this to retrieve the subsequent page. When paginating, all other parameters provided to `ListStreamObjectsRequest` must match the call that provided the page token. x__xgafv: string, V1 error format. Allowed values 1 - v1 error format 2 - v2 error format Returns: An object of the form: { # Response containing the objects for a stream. "nextPageToken": "A String", # A token, which can be sent as `page_token` to retrieve the next page. "streamObjects": [ # List of stream objects. { # A specific stream object (e.g a specific DB table). "backfillJob": { # Represents a backfill job on a specific stream object. # The latest backfill job that was initiated for the stream object. "errors": [ # Output only. Errors which caused the backfill job to fail. { # Represent a user-facing Error. "details": { # Additional information about the error. "a_key": "A String", }, "errorTime": "A String", # The time when the error occurred. "errorUuid": "A String", # A unique identifier for this specific error, allowing it to be traced throughout the system in logs and API responses. "message": "A String", # A message containing more information about the error that occurred. "reason": "A String", # A title that explains the reason for the error. }, ], "lastEndTime": "A String", # Output only. Backfill job's end time. "lastStartTime": "A String", # Output only. Backfill job's start time. "state": "A String", # Output only. Backfill job state. "trigger": "A String", # Backfill job's triggering reason. }, "createTime": "A String", # Output only. The creation time of the object. "displayName": "A String", # Required. Display name. "errors": [ # Output only. Active errors on the object. { # Represent a user-facing Error. "details": { # Additional information about the error. "a_key": "A String", }, "errorTime": "A String", # The time when the error occurred. "errorUuid": "A String", # A unique identifier for this specific error, allowing it to be traced throughout the system in logs and API responses. "message": "A String", # A message containing more information about the error that occurred. "reason": "A String", # A title that explains the reason for the error. }, ], "name": "A String", # Output only. The object resource's name. "sourceObject": { # Represents an identifier of an object in the data source. # The object identifier in the data source. "mysqlIdentifier": { # Mysql data source object identifier. # Mysql data source object identifier. "database": "A String", # Required. The database name. "table": "A String", # Required. The table name. }, "oracleIdentifier": { # Oracle data source object identifier. # Oracle data source object identifier. "schema": "A String", # Required. The schema name. "table": "A String", # Required. The table name. }, "postgresqlIdentifier": { # PostgreSQL data source object identifier. # PostgreSQL data source object identifier. "schema": "A String", # Required. The schema name. "table": "A String", # Required. The table name. }, "sqlServerIdentifier": { # SQLServer data source object identifier. # SQLServer data source object identifier. "schema": "A String", # Required. The schema name. "table": "A String", # Required. The table name. }, }, "updateTime": "A String", # Output only. The last update time of the object. }, ], }
list_next()
Retrieves the next page of results. Args: previous_request: The request for the previous page. (required) previous_response: The response from the request for the previous page. (required) Returns: A request object that you can call 'execute()' on to request the next page. Returns None if there are no more items in the collection.
lookup(parent, body=None, x__xgafv=None)
Use this method to look up a stream object by its source object identifier. Args: parent: string, Required. The parent stream that owns the collection of objects. (required) body: object, The request body. The object takes the form of: { # Request for looking up a specific stream object by its source object identifier. "sourceObjectIdentifier": { # Represents an identifier of an object in the data source. # Required. The source object identifier which maps to the stream object. "mysqlIdentifier": { # Mysql data source object identifier. # Mysql data source object identifier. "database": "A String", # Required. The database name. "table": "A String", # Required. The table name. }, "oracleIdentifier": { # Oracle data source object identifier. # Oracle data source object identifier. "schema": "A String", # Required. The schema name. "table": "A String", # Required. The table name. }, "postgresqlIdentifier": { # PostgreSQL data source object identifier. # PostgreSQL data source object identifier. "schema": "A String", # Required. The schema name. "table": "A String", # Required. The table name. }, "sqlServerIdentifier": { # SQLServer data source object identifier. # SQLServer data source object identifier. "schema": "A String", # Required. The schema name. "table": "A String", # Required. The table name. }, }, } x__xgafv: string, V1 error format. Allowed values 1 - v1 error format 2 - v2 error format Returns: An object of the form: { # A specific stream object (e.g a specific DB table). "backfillJob": { # Represents a backfill job on a specific stream object. # The latest backfill job that was initiated for the stream object. "errors": [ # Output only. Errors which caused the backfill job to fail. { # Represent a user-facing Error. "details": { # Additional information about the error. "a_key": "A String", }, "errorTime": "A String", # The time when the error occurred. "errorUuid": "A String", # A unique identifier for this specific error, allowing it to be traced throughout the system in logs and API responses. "message": "A String", # A message containing more information about the error that occurred. "reason": "A String", # A title that explains the reason for the error. }, ], "lastEndTime": "A String", # Output only. Backfill job's end time. "lastStartTime": "A String", # Output only. Backfill job's start time. "state": "A String", # Output only. Backfill job state. "trigger": "A String", # Backfill job's triggering reason. }, "createTime": "A String", # Output only. The creation time of the object. "displayName": "A String", # Required. Display name. "errors": [ # Output only. Active errors on the object. { # Represent a user-facing Error. "details": { # Additional information about the error. "a_key": "A String", }, "errorTime": "A String", # The time when the error occurred. "errorUuid": "A String", # A unique identifier for this specific error, allowing it to be traced throughout the system in logs and API responses. "message": "A String", # A message containing more information about the error that occurred. "reason": "A String", # A title that explains the reason for the error. }, ], "name": "A String", # Output only. The object resource's name. "sourceObject": { # Represents an identifier of an object in the data source. # The object identifier in the data source. "mysqlIdentifier": { # Mysql data source object identifier. # Mysql data source object identifier. "database": "A String", # Required. The database name. "table": "A String", # Required. The table name. }, "oracleIdentifier": { # Oracle data source object identifier. # Oracle data source object identifier. "schema": "A String", # Required. The schema name. "table": "A String", # Required. The table name. }, "postgresqlIdentifier": { # PostgreSQL data source object identifier. # PostgreSQL data source object identifier. "schema": "A String", # Required. The schema name. "table": "A String", # Required. The table name. }, "sqlServerIdentifier": { # SQLServer data source object identifier. # SQLServer data source object identifier. "schema": "A String", # Required. The schema name. "table": "A String", # Required. The table name. }, }, "updateTime": "A String", # Output only. The last update time of the object. }
startBackfillJob(object, body=None, x__xgafv=None)
Use this method to start a backfill job for the specified stream object. Args: object: string, Required. The name of the stream object resource to start a backfill job for. (required) body: object, The request body. The object takes the form of: { # Request for manually initiating a backfill job for a specific stream object. } x__xgafv: string, V1 error format. Allowed values 1 - v1 error format 2 - v2 error format Returns: An object of the form: { # Response for manually initiating a backfill job for a specific stream object. "object": { # A specific stream object (e.g a specific DB table). # The stream object resource a backfill job was started for. "backfillJob": { # Represents a backfill job on a specific stream object. # The latest backfill job that was initiated for the stream object. "errors": [ # Output only. Errors which caused the backfill job to fail. { # Represent a user-facing Error. "details": { # Additional information about the error. "a_key": "A String", }, "errorTime": "A String", # The time when the error occurred. "errorUuid": "A String", # A unique identifier for this specific error, allowing it to be traced throughout the system in logs and API responses. "message": "A String", # A message containing more information about the error that occurred. "reason": "A String", # A title that explains the reason for the error. }, ], "lastEndTime": "A String", # Output only. Backfill job's end time. "lastStartTime": "A String", # Output only. Backfill job's start time. "state": "A String", # Output only. Backfill job state. "trigger": "A String", # Backfill job's triggering reason. }, "createTime": "A String", # Output only. The creation time of the object. "displayName": "A String", # Required. Display name. "errors": [ # Output only. Active errors on the object. { # Represent a user-facing Error. "details": { # Additional information about the error. "a_key": "A String", }, "errorTime": "A String", # The time when the error occurred. "errorUuid": "A String", # A unique identifier for this specific error, allowing it to be traced throughout the system in logs and API responses. "message": "A String", # A message containing more information about the error that occurred. "reason": "A String", # A title that explains the reason for the error. }, ], "name": "A String", # Output only. The object resource's name. "sourceObject": { # Represents an identifier of an object in the data source. # The object identifier in the data source. "mysqlIdentifier": { # Mysql data source object identifier. # Mysql data source object identifier. "database": "A String", # Required. The database name. "table": "A String", # Required. The table name. }, "oracleIdentifier": { # Oracle data source object identifier. # Oracle data source object identifier. "schema": "A String", # Required. The schema name. "table": "A String", # Required. The table name. }, "postgresqlIdentifier": { # PostgreSQL data source object identifier. # PostgreSQL data source object identifier. "schema": "A String", # Required. The schema name. "table": "A String", # Required. The table name. }, "sqlServerIdentifier": { # SQLServer data source object identifier. # SQLServer data source object identifier. "schema": "A String", # Required. The schema name. "table": "A String", # Required. The table name. }, }, "updateTime": "A String", # Output only. The last update time of the object. }, }
stopBackfillJob(object, body=None, x__xgafv=None)
Use this method to stop a backfill job for the specified stream object. Args: object: string, Required. The name of the stream object resource to stop the backfill job for. (required) body: object, The request body. The object takes the form of: { # Request for manually stopping a running backfill job for a specific stream object. } x__xgafv: string, V1 error format. Allowed values 1 - v1 error format 2 - v2 error format Returns: An object of the form: { # Response for manually stop a backfill job for a specific stream object. "object": { # A specific stream object (e.g a specific DB table). # The stream object resource the backfill job was stopped for. "backfillJob": { # Represents a backfill job on a specific stream object. # The latest backfill job that was initiated for the stream object. "errors": [ # Output only. Errors which caused the backfill job to fail. { # Represent a user-facing Error. "details": { # Additional information about the error. "a_key": "A String", }, "errorTime": "A String", # The time when the error occurred. "errorUuid": "A String", # A unique identifier for this specific error, allowing it to be traced throughout the system in logs and API responses. "message": "A String", # A message containing more information about the error that occurred. "reason": "A String", # A title that explains the reason for the error. }, ], "lastEndTime": "A String", # Output only. Backfill job's end time. "lastStartTime": "A String", # Output only. Backfill job's start time. "state": "A String", # Output only. Backfill job state. "trigger": "A String", # Backfill job's triggering reason. }, "createTime": "A String", # Output only. The creation time of the object. "displayName": "A String", # Required. Display name. "errors": [ # Output only. Active errors on the object. { # Represent a user-facing Error. "details": { # Additional information about the error. "a_key": "A String", }, "errorTime": "A String", # The time when the error occurred. "errorUuid": "A String", # A unique identifier for this specific error, allowing it to be traced throughout the system in logs and API responses. "message": "A String", # A message containing more information about the error that occurred. "reason": "A String", # A title that explains the reason for the error. }, ], "name": "A String", # Output only. The object resource's name. "sourceObject": { # Represents an identifier of an object in the data source. # The object identifier in the data source. "mysqlIdentifier": { # Mysql data source object identifier. # Mysql data source object identifier. "database": "A String", # Required. The database name. "table": "A String", # Required. The table name. }, "oracleIdentifier": { # Oracle data source object identifier. # Oracle data source object identifier. "schema": "A String", # Required. The schema name. "table": "A String", # Required. The table name. }, "postgresqlIdentifier": { # PostgreSQL data source object identifier. # PostgreSQL data source object identifier. "schema": "A String", # Required. The schema name. "table": "A String", # Required. The table name. }, "sqlServerIdentifier": { # SQLServer data source object identifier. # SQLServer data source object identifier. "schema": "A String", # Required. The schema name. "table": "A String", # Required. The table name. }, }, "updateTime": "A String", # Output only. The last update time of the object. }, }