Skip to content

Data stream

DataStream(**kwargs)

Bases: Resource

Implementation of a resource for data streams.

This resource defines the data model used by resource container (model.container.DataStreams). It inherits from Pydantic's BaseModel to get all its superpowers, which are used to parse, validate the API response and to easily switch between the Python representation (both serialized and deserialized) and Java representation (serialized only).

convert_to_pandas_representation()

Returns the dictionary representation of a data stream to be used when creating a pandas Dataframe.

RETURNS DESCRIPTION
pandas_repr

Pandas representation of the resource as a dictionary, which is then used by the respource container to create a data frame from a collection of resources.

TYPE: Dict[str, Any]

to_dict(use_source_names=True)

Returns the resource in dictionary representation.

PARAMETER DESCRIPTION
use_source_names

Indicates if the dictionary keys are in python representation or equally named to the StreamPipes backend

DEFAULT: True

RETURNS DESCRIPTION
resource

The resource as dictionary representation

TYPE: Dict[str, Any]