Streaming Endpoints#
Note
There are two main classes related to streaming endpoint handling in Dataiku’s Python APIs:
dataiku.StreamingEndpoint
in thedataiku
package. It was initially designed for usage within DSS in recipes and Jupyter notebooks.dataikuapi.dss.streaming_endpoint.DSSStreamingEndpoint
in thedataikuapi
package. It was initially designed for usage outside of DSS.
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.
|
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.
A streaming endpoint on the DSS instance. |
|
|
A handle to interact with the execution of a continuous recipe on the DSS instance. |