Create

async AsyncCogniteClient.data_modeling.streams.create(

items: StreamWrite | Sequence[StreamWrite],

) → Stream | StreamList

Create streams.

Parameters:

items (StreamWrite | Sequence[StreamWrite]) – One or more streams to create.

Returns:

The created stream or streams.

Return type:

Stream | StreamList

Examples

Create a single stream from a template:

>>> from cognite.client import CogniteClient
>>> from cognite.client.data_classes.data_modeling.streams import (
...     StreamWrite,
...     StreamTemplate,
...     StreamTemplateWriteSettings,
... )
>>> client = CogniteClient()
>>> # async_client = AsyncCogniteClient()  # another option
>>> res = client.data_modeling.streams.create(
...     StreamWrite(
...         external_id="my-stream",
...         settings=StreamTemplateWriteSettings(
...             template=StreamTemplate(name="ImmutableTestStream"),
...         ),
...     )
... )