Streaming Endpoints#


There are two main classes related to streaming endpoint handling in Dataiku’s Python APIs:

Both classes have fairly similar capabilities, but we recommend using dataiku.StreamingEndpoint within DSS.

For more details on the two packages, please see Getting started.

Reference documentation#

Use the following classes to interact with streaming endpoints in Python recipes and notebooks.

dataiku.StreamingEndpoint(id[, project_key])

This is a handle to obtain readers and writers on a dataiku streaming endpoint.


Handle to read a streaming endpoint.


Handle to write using the continuous write API to a dataset or streaming endpoint.


Handle to write using the continuous write API to a streaming endpoint.

Use the following class preferably outside of DSS.