viam.gen.app.datapipelines.v1.data_pipelines_pb2 ================================================ .. py:module:: viam.gen.app.datapipelines.v1.data_pipelines_pb2 .. autoapi-nested-parse:: @generated by mypy-protobuf. Do not edit manually! isort:skip_file Attributes ---------- .. autoapisummary:: viam.gen.app.datapipelines.v1.data_pipelines_pb2.DESCRIPTOR viam.gen.app.datapipelines.v1.data_pipelines_pb2.global___DataPipeline viam.gen.app.datapipelines.v1.data_pipelines_pb2.global___GetDataPipelineRequest viam.gen.app.datapipelines.v1.data_pipelines_pb2.global___GetDataPipelineResponse viam.gen.app.datapipelines.v1.data_pipelines_pb2.global___ListDataPipelinesRequest viam.gen.app.datapipelines.v1.data_pipelines_pb2.global___ListDataPipelinesResponse viam.gen.app.datapipelines.v1.data_pipelines_pb2.global___CreateDataPipelineRequest viam.gen.app.datapipelines.v1.data_pipelines_pb2.global___CreateDataPipelineResponse viam.gen.app.datapipelines.v1.data_pipelines_pb2.global___UpdateDataPipelineRequest viam.gen.app.datapipelines.v1.data_pipelines_pb2.global___UpdateDataPipelineResponse viam.gen.app.datapipelines.v1.data_pipelines_pb2.global___DeleteDataPipelineRequest viam.gen.app.datapipelines.v1.data_pipelines_pb2.global___DeleteDataPipelineResponse Classes ------- .. autoapisummary:: viam.gen.app.datapipelines.v1.data_pipelines_pb2.DataPipeline viam.gen.app.datapipelines.v1.data_pipelines_pb2.GetDataPipelineRequest viam.gen.app.datapipelines.v1.data_pipelines_pb2.GetDataPipelineResponse viam.gen.app.datapipelines.v1.data_pipelines_pb2.ListDataPipelinesRequest viam.gen.app.datapipelines.v1.data_pipelines_pb2.ListDataPipelinesResponse viam.gen.app.datapipelines.v1.data_pipelines_pb2.CreateDataPipelineRequest viam.gen.app.datapipelines.v1.data_pipelines_pb2.CreateDataPipelineResponse viam.gen.app.datapipelines.v1.data_pipelines_pb2.UpdateDataPipelineRequest viam.gen.app.datapipelines.v1.data_pipelines_pb2.UpdateDataPipelineResponse viam.gen.app.datapipelines.v1.data_pipelines_pb2.DeleteDataPipelineRequest viam.gen.app.datapipelines.v1.data_pipelines_pb2.DeleteDataPipelineResponse Module Contents --------------- .. py:data:: DESCRIPTOR :type: google.protobuf.descriptor.FileDescriptor .. py:class:: DataPipeline(*, id: str = ..., organization_id: str = ..., name: str = ..., mql_binary: collections.abc.Iterable[bytes] | None = ..., schedule: str = ..., enabled: bool = ..., created_on: google.protobuf.timestamp_pb2.Timestamp | None = ..., updated_at: google.protobuf.timestamp_pb2.Timestamp | None = ...) Bases: :py:obj:`google.protobuf.message.Message` Abstract base class for protocol messages. Protocol message classes are almost always generated by the protocol compiler. These generated types subclass Message and implement the methods shown below. .. py:attribute:: id :type: str .. py:attribute:: organization_id :type: str The associated Viam organization ID. .. py:attribute:: name :type: str A unique identifier at the org level. .. py:attribute:: schedule :type: str A cron expression representing the expected execution schedule in UTC (note this also defines the input time window; an hourly schedule would process 1 hour of data at a time). .. py:attribute:: enabled :type: bool Whether or not the pipeline is enabled. .. py:property:: mql_binary :type: google.protobuf.internal.containers.RepeatedScalarFieldContainer[bytes] A MongoDB aggregation pipeline as a list of BSON documents, where each document is one stage in the pipeline. .. py:property:: created_on :type: google.protobuf.timestamp_pb2.Timestamp The time the pipeline was created. .. py:property:: updated_at :type: google.protobuf.timestamp_pb2.Timestamp The time the pipeline was last updated. .. py:method:: HasField(field_name: Literal['created_on', b'created_on', 'updated_at', b'updated_at']) -> bool Checks if a certain field is set for the message. For a oneof group, checks if any field inside is set. Note that if the field_name is not defined in the message descriptor, :exc:`ValueError` will be raised. :param field_name: The name of the field to check for presence. :type field_name: str :returns: Whether a value has been set for the named field. :rtype: bool :raises ValueError: if the `field_name` is not a member of this message. .. py:data:: global___DataPipeline .. py:class:: GetDataPipelineRequest(*, id: str = ...) Bases: :py:obj:`google.protobuf.message.Message` Abstract base class for protocol messages. Protocol message classes are almost always generated by the protocol compiler. These generated types subclass Message and implement the methods shown below. .. py:attribute:: id :type: str The ID of the data pipeline to retrieve. .. py:data:: global___GetDataPipelineRequest .. py:class:: GetDataPipelineResponse(*, data_pipeline: global___DataPipeline | None = ...) Bases: :py:obj:`google.protobuf.message.Message` Abstract base class for protocol messages. Protocol message classes are almost always generated by the protocol compiler. These generated types subclass Message and implement the methods shown below. .. py:property:: data_pipeline :type: global___DataPipeline .. py:method:: HasField(field_name: Literal['data_pipeline', b'data_pipeline']) -> bool Checks if a certain field is set for the message. For a oneof group, checks if any field inside is set. Note that if the field_name is not defined in the message descriptor, :exc:`ValueError` will be raised. :param field_name: The name of the field to check for presence. :type field_name: str :returns: Whether a value has been set for the named field. :rtype: bool :raises ValueError: if the `field_name` is not a member of this message. .. py:data:: global___GetDataPipelineResponse .. py:class:: ListDataPipelinesRequest(*, organization_id: str = ...) Bases: :py:obj:`google.protobuf.message.Message` Abstract base class for protocol messages. Protocol message classes are almost always generated by the protocol compiler. These generated types subclass Message and implement the methods shown below. .. py:attribute:: organization_id :type: str The associated Viam organization ID. .. py:data:: global___ListDataPipelinesRequest .. py:class:: ListDataPipelinesResponse(*, data_pipelines: collections.abc.Iterable[global___DataPipeline] | None = ...) Bases: :py:obj:`google.protobuf.message.Message` Abstract base class for protocol messages. Protocol message classes are almost always generated by the protocol compiler. These generated types subclass Message and implement the methods shown below. .. py:property:: data_pipelines :type: google.protobuf.internal.containers.RepeatedCompositeFieldContainer[global___DataPipeline] .. py:data:: global___ListDataPipelinesResponse .. py:class:: CreateDataPipelineRequest(*, organization_id: str = ..., name: str = ..., mql_binary: collections.abc.Iterable[bytes] | None = ..., schedule: str = ...) Bases: :py:obj:`google.protobuf.message.Message` Abstract base class for protocol messages. Protocol message classes are almost always generated by the protocol compiler. These generated types subclass Message and implement the methods shown below. .. py:attribute:: organization_id :type: str The associated Viam organization ID. .. py:attribute:: name :type: str A unique identifier at the org level. .. py:attribute:: schedule :type: str A cron expression representing the expected execution schedule in UTC (note this also defines the input time window; an hourly schedule would process 1 hour of data at a time). .. py:property:: mql_binary :type: google.protobuf.internal.containers.RepeatedScalarFieldContainer[bytes] A MongoDB aggregation pipeline as a list of BSON documents, where each document is one stage in the pipeline. .. py:data:: global___CreateDataPipelineRequest .. py:class:: CreateDataPipelineResponse(*, id: str = ...) Bases: :py:obj:`google.protobuf.message.Message` Abstract base class for protocol messages. Protocol message classes are almost always generated by the protocol compiler. These generated types subclass Message and implement the methods shown below. .. py:attribute:: id :type: str The ID of the newly created data pipeline. .. py:data:: global___CreateDataPipelineResponse .. py:class:: UpdateDataPipelineRequest(*, id: str = ..., name: str = ..., mql_binary: collections.abc.Iterable[bytes] | None = ..., schedule: str = ..., enabled: bool = ...) Bases: :py:obj:`google.protobuf.message.Message` Abstract base class for protocol messages. Protocol message classes are almost always generated by the protocol compiler. These generated types subclass Message and implement the methods shown below. .. py:attribute:: id :type: str The ID of the data pipeline to update. .. py:attribute:: name :type: str A unique identifier at the org level. .. py:attribute:: schedule :type: str A cron expression representing the expected execution schedule in UTC (note this also defines the input time window; an hourly schedule would process 1 hour of data at a time). .. py:attribute:: enabled :type: bool Whether or not the pipeline is enabled. .. py:property:: mql_binary :type: google.protobuf.internal.containers.RepeatedScalarFieldContainer[bytes] A MongoDB aggregation pipeline as a list of BSON documents, where each document is one stage in the pipeline. .. py:data:: global___UpdateDataPipelineRequest .. py:class:: UpdateDataPipelineResponse Bases: :py:obj:`google.protobuf.message.Message` Abstract base class for protocol messages. Protocol message classes are almost always generated by the protocol compiler. These generated types subclass Message and implement the methods shown below. .. py:data:: global___UpdateDataPipelineResponse .. py:class:: DeleteDataPipelineRequest(*, id: str = ...) Bases: :py:obj:`google.protobuf.message.Message` Abstract base class for protocol messages. Protocol message classes are almost always generated by the protocol compiler. These generated types subclass Message and implement the methods shown below. .. py:attribute:: id :type: str The ID of the data pipeline to delete. .. py:data:: global___DeleteDataPipelineRequest .. py:class:: DeleteDataPipelineResponse Bases: :py:obj:`google.protobuf.message.Message` Abstract base class for protocol messages. Protocol message classes are almost always generated by the protocol compiler. These generated types subclass Message and implement the methods shown below. .. py:data:: global___DeleteDataPipelineResponse