diff --git a/docs-python/dev/assets/_mkdocstrings.css b/docs-python/dev/assets/_mkdocstrings.css index 049a254b9..4b7d98b83 100644 --- a/docs-python/dev/assets/_mkdocstrings.css +++ b/docs-python/dev/assets/_mkdocstrings.css @@ -26,39 +26,84 @@ float: right; } -/* Keep headings consistent. */ -h1.doc-heading, -h2.doc-heading, -h3.doc-heading, -h4.doc-heading, -h5.doc-heading, -h6.doc-heading { - font-weight: 400; - line-height: 1.5; - color: inherit; - text-transform: none; +/* Symbols in Navigation and ToC. */ +:root, +[data-md-color-scheme="default"] { + --doc-symbol-attribute-fg-color: #953800; + --doc-symbol-function-fg-color: #8250df; + --doc-symbol-method-fg-color: #8250df; + --doc-symbol-class-fg-color: #0550ae; + --doc-symbol-module-fg-color: #5cad0f; + + --doc-symbol-attribute-bg-color: #9538001a; + --doc-symbol-function-bg-color: #8250df1a; + --doc-symbol-method-bg-color: #8250df1a; + --doc-symbol-class-bg-color: #0550ae1a; + --doc-symbol-module-bg-color: #5cad0f1a; +} + +[data-md-color-scheme="slate"] { + --doc-symbol-attribute-fg-color: #ffa657; + --doc-symbol-function-fg-color: #d2a8ff; + --doc-symbol-method-fg-color: #d2a8ff; + --doc-symbol-class-fg-color: #79c0ff; + --doc-symbol-module-fg-color: #baff79; + + --doc-symbol-attribute-bg-color: #ffa6571a; + --doc-symbol-function-bg-color: #d2a8ff1a; + --doc-symbol-method-bg-color: #d2a8ff1a; + --doc-symbol-class-bg-color: #79c0ff1a; + --doc-symbol-module-bg-color: #baff791a; +} + +code.doc-symbol { + border-radius: .1rem; + font-size: .85em; + padding: 0 .3em; + font-weight: bold; +} + +code.doc-symbol-attribute { + color: var(--doc-symbol-attribute-fg-color); + background-color: var(--doc-symbol-attribute-bg-color); +} + +code.doc-symbol-attribute::after { + content: "attr"; +} + +code.doc-symbol-function { + color: var(--doc-symbol-function-fg-color); + background-color: var(--doc-symbol-function-bg-color); +} + +code.doc-symbol-function::after { + content: "func"; } -h1.doc-heading { - font-size: 1.6rem; +code.doc-symbol-method { + color: var(--doc-symbol-method-fg-color); + background-color: var(--doc-symbol-method-bg-color); } -h2.doc-heading { - font-size: 1.2rem; +code.doc-symbol-method::after { + content: "meth"; } -h3.doc-heading { - font-size: 1.15rem; +code.doc-symbol-class { + color: var(--doc-symbol-class-fg-color); + background-color: var(--doc-symbol-class-bg-color); } -h4.doc-heading { - font-size: 1.10rem; +code.doc-symbol-class::after { + content: "class"; } -h5.doc-heading { - font-size: 1.05rem; +code.doc-symbol-module { + color: var(--doc-symbol-module-fg-color); + background-color: var(--doc-symbol-module-bg-color); } -h6.doc-heading { - font-size: 1rem; +code.doc-symbol-module::after { + content: "mod"; } \ No newline at end of file diff --git a/docs-python/dev/index.html b/docs-python/dev/index.html index 4029ebe64..b76bba434 100644 --- a/docs-python/dev/index.html +++ b/docs-python/dev/index.html @@ -2235,17 +2235,7 @@

🏑 Home

StreamPipes Logo with Python StreamPipes Logo with Python

StreamPipes is a self-service (Industrial) IoT toolbox to enable non-technical users to connect, analyze and explore IoT data streams.

-


-
-

Dependency issue with StreamPipes Python 0.92.0

-

In StreamPipes Python 0.92.0 there is a problem with the required dependencies.
-Pydantic has recently released the new version 2.0 with many exciting improvements, but also some breaking changes. -Unfortunately, we didn't limit our requirements strictly enough, so yydantic 2.0 is installed together with streampipes, which is not (yet) compatible.
-To fix this bug, simply run the following command after installing streampipes, or adjust your dependencies accordingly:

-
pip install "pydantic<2.0" "pydantic_core<2.0"
-
-
-


+

Apache StreamPipes for Python 🐍

Apache StreamPipes meets Python! We are working highly motivated on a Python library to interact with StreamPipes. diff --git a/docs-python/dev/objects.inv b/docs-python/dev/objects.inv index d8ee06e79..fbaa9aa28 100644 Binary files a/docs-python/dev/objects.inv and b/docs-python/dev/objects.inv differ diff --git a/docs-python/dev/reference/client/client/index.html b/docs-python/dev/reference/client/client/index.html index a2b7f6b62..58d0f9e9f 100644 --- a/docs-python/dev/reference/client/client/index.html +++ b/docs-python/dev/reference/client/client/index.html @@ -812,7 +812,7 @@

  • - streampipes.client.client + client
  • @@ -841,14 +841,14 @@
  • - create() + create
  • - describe() + describe
  • @@ -2238,7 +2238,7 @@
  • - streampipes.client.client + client
  • @@ -2267,14 +2267,14 @@
  • - create() + create
  • - describe() + describe
  • @@ -2307,6 +2307,7 @@

    Client

    +
    @@ -2330,7 +2331,7 @@

    Client

    -StreamPipesClient(client_config, logging_level=logging.INFO) + StreamPipesClient(client_config, logging_level=logging.INFO)

    @@ -2383,7 +2384,7 @@

    DEFAULT: - logging.INFO + INFO

    @@ -2402,7 +2403,7 @@

    - dataLakeMeasureApi + dataLakeMeasureApi

    Instance of the data lake measure endpoint

    @@ -2416,7 +2417,7 @@

    - dataStreamApi + dataStreamApi

    Instance of the data stream endpoint

    @@ -2507,7 +2508,7 @@

    -base_api_path: str + base_api_path: str property @@ -2557,7 +2558,7 @@

    -http_headers: Dict[str, str] + http_headers: Dict[str, str] property @@ -2612,7 +2613,7 @@

    -create(client_config, logging_level=logging.INFO) + create(client_config, logging_level=logging.INFO) classmethod @@ -2663,7 +2664,7 @@

    DEFAULT: - logging.INFO + INFO

    @@ -2706,7 +2707,7 @@

    -describe() + describe()

    @@ -2763,6 +2764,7 @@

    - streampipes.client.config + config @@ -2204,7 +2204,7 @@
  • - streampipes.client.config + config
  • @@ -2239,6 +2239,7 @@

    Config

    +
    @@ -2260,8 +2261,7 @@

    Config

    - StreamPipesClientConfig - + StreamPipesClientConfig(credential_provider, host_address, https_disabled=False, port=80) dataclass @@ -2379,6 +2379,7 @@

    - streampipes.client.credential_provider + credential_provider @@ -867,7 +867,7 @@
  • - make_headers() + make_headers
  • @@ -887,7 +887,7 @@
  • - from_env() + from_env
  • @@ -2237,7 +2237,7 @@
  • - streampipes.client.credential_provider + credential_provider
  • @@ -2252,7 +2252,7 @@
  • - make_headers() + make_headers
  • @@ -2272,7 +2272,7 @@
  • - from_env() + from_env
  • @@ -2305,6 +2305,7 @@

    Credential provider

    +
    @@ -2361,7 +2362,7 @@

    -make_headers(http_headers=None) + make_headers(http_headers=None)

    @@ -2443,6 +2444,7 @@

    +

    @@ -2450,7 +2452,7 @@

    -StreamPipesApiKeyCredentials(username=None, api_key=None) + StreamPipesApiKeyCredentials(username=None, api_key=None)

    @@ -2544,7 +2546,7 @@

    -from_env(username_env, api_key_env) + from_env(username_env, api_key_env) classmethod @@ -2659,6 +2661,7 @@

    - streampipes.endpoint.api.data_lake_measure + data_lake_measure @@ -1021,7 +1021,7 @@
  • - get() + get
  • @@ -1048,7 +1048,7 @@
  • - build_query_string() + build_query_string
  • @@ -2253,7 +2253,7 @@
  • - streampipes.endpoint.api.data_lake_measure + data_lake_measure
  • @@ -2268,7 +2268,7 @@
  • - get() + get
  • @@ -2295,7 +2295,7 @@
  • - build_query_string() + build_query_string
  • @@ -2335,6 +2335,7 @@

    Data lake measure

    +
    @@ -2357,8 +2358,7 @@

    Data lake measure

    - DataLakeMeasureEndpoint - + DataLakeMeasureEndpoint(parent_client)

    @@ -2454,7 +2454,7 @@

    -get(identifier, **kwargs) + get(identifier, **kwargs)

    @@ -2557,6 +2557,7 @@

    +

    @@ -2572,7 +2573,7 @@

    - Bases: BaseModel

    + Bases: BaseModel

    Config class describing the parameters of the get() method for measurements.

    @@ -2592,7 +2593,7 @@

    - columns + columns

    A comma separated list of column names (e.g., time,value)
    @@ -2608,7 +2609,7 @@

    - end_date + end_date

    Restricts queried data to be younger than the specified time.

    @@ -2622,7 +2623,7 @@

    - limit + limit

    Amount of records returned at maximum (default: 1000)
    @@ -2637,7 +2638,7 @@

    - offset + offset

    Offset to be applied to returned data
    @@ -2652,7 +2653,7 @@

    - order + order

    Ordering of query results
    @@ -2667,7 +2668,7 @@

    - page_no + page_no

    Page number used for paging operation
    @@ -2682,7 +2683,7 @@

    - start_date + start_date

    Restricts queried data to be older than the specified time

    @@ -2745,6 +2746,7 @@

    -build_query_string() + build_query_string()

    @@ -2805,6 +2807,7 @@

    @@ -2829,6 +2832,7 @@

    - streampipes.endpoint.api.data_stream + data_stream @@ -2206,7 +2206,7 @@
  • - streampipes.endpoint.api.data_stream + data_stream
  • @@ -2241,6 +2241,7 @@

    Data stream

    +
    @@ -2262,8 +2263,7 @@

    Data stream

    - DataStreamEndpoint - + DataStreamEndpoint(parent_client)

    @@ -2318,6 +2318,7 @@

    - streampipes.endpoint.api.version + version @@ -1061,21 +1061,21 @@
  • - all() + all
  • - get() + get
  • - post() + post
  • @@ -2233,7 +2233,7 @@
  • - streampipes.endpoint.api.version + version
  • @@ -2248,21 +2248,21 @@
  • - all() + all
  • - get() + get
  • - post() + post
  • @@ -2295,6 +2295,7 @@

    Version

    +
    @@ -2316,8 +2317,7 @@

    Version

    - VersionEndpoint - + VersionEndpoint(parent_client)

    @@ -2348,6 +2348,10 @@

    StreamPipesClient the endpoint is attached to.

    + + TYPE: + StreamPipesClient +

    @@ -2393,7 +2397,7 @@

    -all() + all()

    @@ -2438,7 +2442,7 @@

    -get(identifier, **kwargs) + get(identifier, **kwargs)

    @@ -2514,7 +2518,7 @@

    -post(resource) + post(resource)

    @@ -2559,6 +2563,7 @@

    - streampipes.endpoint.endpoint + endpoint @@ -937,28 +937,28 @@
  • - all() + all
  • - build_url() + build_url
  • - get() + get
  • - post() + post
  • @@ -992,7 +992,7 @@
  • - configure() + configure
  • @@ -2272,7 +2272,7 @@
  • - streampipes.endpoint.endpoint + endpoint
  • @@ -2287,28 +2287,28 @@
  • - all() + all
  • - build_url() + build_url
  • - get() + get
  • - post() + post
  • @@ -2342,7 +2342,7 @@
  • - configure() + configure
  • @@ -2375,6 +2375,7 @@

    Endpoint

    +
    @@ -2398,8 +2399,7 @@

    Endpoint

    - APIEndpoint - + APIEndpoint(parent_client)

    @@ -2432,7 +2432,7 @@

    -all() + all()

    @@ -2482,7 +2482,7 @@

    -build_url() + build_url()

    @@ -2530,7 +2530,7 @@

    -get(identifier, **kwargs) + get(identifier, **kwargs)

    @@ -2605,7 +2605,7 @@

    -post(resource) + post(resource)

    @@ -2676,6 +2676,7 @@

    +
    @@ -2683,7 +2684,7 @@

    -Endpoint(parent_client) + Endpoint(parent_client)

    @@ -2743,6 +2744,7 @@

    +
    @@ -2750,7 +2752,7 @@

    -MessagingEndpoint(parent_client) + MessagingEndpoint(parent_client)

    @@ -2781,7 +2783,7 @@

    -broker: Broker + broker: Broker property @@ -2862,7 +2864,7 @@

    -configure(broker) + configure(broker)

    @@ -2935,6 +2937,7 @@

    - streampipes.endpoint.exceptions + exceptions @@ -2204,7 +2204,7 @@
  • - streampipes.endpoint.exceptions + exceptions
  • @@ -2239,6 +2239,7 @@

    Exceptions

    +
    @@ -2260,7 +2261,7 @@

    Exceptions

    -MessagingEndpointNotConfiguredError(endpoint_name) + MessagingEndpointNotConfiguredError(endpoint_name)

    @@ -2320,6 +2321,7 @@

    +

    diff --git a/docs-python/dev/reference/function_zoo/river_function/index.html b/docs-python/dev/reference/function_zoo/river_function/index.html index 229a67d6d..f449e905b 100644 --- a/docs-python/dev/reference/function_zoo/river_function/index.html +++ b/docs-python/dev/reference/function_zoo/river_function/index.html @@ -1118,7 +1118,7 @@
  • - streampipes.function_zoo.river_function + river_function
  • @@ -1133,21 +1133,21 @@
  • - set_learning() + set_learning
  • - start() + start
  • - stop() + stop
  • @@ -1167,21 +1167,21 @@
  • - onEvent() + onEvent
  • - onServiceStarted() + onServiceStarted
  • - onServiceStopped() + onServiceStopped
  • @@ -2265,7 +2265,7 @@
  • - streampipes.function_zoo.river_function + river_function
  • @@ -2280,21 +2280,21 @@
  • - set_learning() + set_learning
  • - start() + start
  • - stop() + stop
  • @@ -2314,21 +2314,21 @@
  • - onEvent() + onEvent
  • - onServiceStarted() + onServiceStarted
  • - onServiceStopped() + onServiceStopped
  • @@ -2361,6 +2361,7 @@

    River function

    +
    @@ -2380,7 +2381,7 @@

    River function

    -OnlineML(client, stream_ids, model, prediction_type=RuntimeType.STRING.value, supervised=False, target_label=None, on_start=lambda self, context: None, on_event=lambda self, event, streamId: None, on_stop=lambda self: None) + OnlineML(client, stream_ids, model, prediction_type=RuntimeType.STRING.value, supervised=False, target_label=None, on_start=lambda self, context: None, on_event=lambda self, event, streamId: None, on_stop=lambda self: None)

    @@ -2459,7 +2460,7 @@

    DEFAULT: - RuntimeType.STRING.value + value

    @@ -2576,7 +2577,7 @@

    -set_learning(learning) + set_learning(learning)

    @@ -2622,7 +2623,7 @@

    -start() + start()

    @@ -2641,7 +2642,7 @@

    -stop() + stop()

    @@ -2660,6 +2661,7 @@

    @@ -2667,7 +2669,7 @@

    -RiverFunction(function_definition, model, supervised, target_label, on_start, on_event, on_stop) + RiverFunction(function_definition, model, supervised, target_label, on_start, on_event, on_stop)

    @@ -2812,7 +2814,7 @@

    -onEvent(event, streamId) + onEvent(event, streamId)

    @@ -2897,7 +2899,7 @@

    -onServiceStarted(context) + onServiceStarted(context)

    @@ -2968,7 +2970,7 @@

    -onServiceStopped() + onServiceStopped()

    @@ -2987,6 +2989,7 @@

    +

    diff --git a/docs-python/dev/reference/functions/broker/broker/index.html b/docs-python/dev/reference/functions/broker/broker/index.html index a6d9c676f..370622799 100644 --- a/docs-python/dev/reference/functions/broker/broker/index.html +++ b/docs-python/dev/reference/functions/broker/broker/index.html @@ -1304,7 +1304,7 @@
  • - streampipes.functions.broker.broker + broker
  • @@ -1319,14 +1319,14 @@
  • - connect() + connect
  • - disconnect() + disconnect
  • @@ -2226,7 +2226,7 @@
  • - streampipes.functions.broker.broker + broker
  • @@ -2241,14 +2241,14 @@
  • - connect() + connect
  • - disconnect() + disconnect
  • @@ -2281,6 +2281,7 @@

    Broker

    +
    @@ -2333,7 +2334,7 @@

    -connect(data_stream) + connect(data_stream) async @@ -2408,7 +2409,7 @@

    -disconnect() + disconnect() abstractmethod @@ -2457,6 +2458,7 @@

    - streampipes.functions.broker.broker_handler + broker_handler @@ -1345,14 +1345,14 @@
  • - get_broker() + get_broker
  • - get_broker_description() + get_broker_description
  • @@ -2227,7 +2227,7 @@
  • - streampipes.functions.broker.broker_handler + broker_handler
  • @@ -2248,14 +2248,14 @@
  • - get_broker() + get_broker
  • - get_broker_description() + get_broker_description
  • @@ -2283,6 +2283,7 @@

    Broker handler

    +
    @@ -2334,6 +2335,7 @@

    @@ -2341,7 +2343,7 @@

    -UnsupportedBrokerError(broker_name) + UnsupportedBrokerError(broker_name)

    @@ -2372,6 +2374,7 @@

    +

    @@ -2381,7 +2384,7 @@

    -get_broker(data_stream, is_publisher=False) + get_broker(data_stream, is_publisher=False)

    @@ -2481,7 +2484,7 @@

    -get_broker_description(data_stream) + get_broker_description(data_stream)

    diff --git a/docs-python/dev/reference/functions/broker/consumer/index.html b/docs-python/dev/reference/functions/broker/consumer/index.html index 689e069da..cd2f9b84b 100644 --- a/docs-python/dev/reference/functions/broker/consumer/index.html +++ b/docs-python/dev/reference/functions/broker/consumer/index.html @@ -1344,7 +1344,7 @@
  • - streampipes.functions.broker.consumer + consumer
  • @@ -1359,14 +1359,14 @@
  • - connect() + connect
  • - get_message() + get_message
  • @@ -2226,7 +2226,7 @@
  • - streampipes.functions.broker.consumer + consumer
  • @@ -2241,14 +2241,14 @@
  • - connect() + connect
  • - get_message() + get_message
  • @@ -2281,6 +2281,7 @@

    Consumer

    +
    @@ -2333,7 +2334,7 @@

    -connect(data_stream) + connect(data_stream) async @@ -2408,7 +2409,7 @@

    -get_message() + get_message() abstractmethod @@ -2460,6 +2461,7 @@

    - streampipes.functions.broker.kafka.kafka_consumer + kafka_consumer @@ -1463,14 +1463,14 @@
  • - disconnect() + disconnect
  • - get_message() + get_message
  • @@ -2228,7 +2228,7 @@
  • - streampipes.functions.broker.kafka.kafka_consumer + kafka_consumer
  • @@ -2243,14 +2243,14 @@
  • - disconnect() + disconnect
  • - get_message() + get_message
  • @@ -2283,6 +2283,7 @@

    Kafka consumer

    +
    @@ -2334,7 +2335,7 @@

    -disconnect() + disconnect() async @@ -2382,7 +2383,7 @@

    -get_message() + get_message()

    @@ -2430,6 +2431,7 @@

    - streampipes.functions.broker.kafka.kafka_message_fetcher + kafka_message_fetcher @@ -2215,7 +2215,7 @@
  • - streampipes.functions.broker.kafka.kafka_message_fetcher + kafka_message_fetcher
  • @@ -2257,6 +2257,7 @@

    Kafka message fetcher

    +
    @@ -2276,7 +2277,7 @@

    Kafka message fetcher

    -KafkaMessage(data) + KafkaMessage(data)

    @@ -2328,6 +2329,7 @@

    +

    @@ -2335,7 +2337,7 @@

    -KafkaMessageFetcher(consumer) + KafkaMessageFetcher(consumer)

    @@ -2391,6 +2393,7 @@

    - streampipes.functions.broker.kafka.kafka_publisher + kafka_publisher @@ -1503,14 +1503,14 @@
  • - disconnect() + disconnect
  • - publish_event() + publish_event
  • @@ -2228,7 +2228,7 @@
  • - streampipes.functions.broker.kafka.kafka_publisher + kafka_publisher
  • @@ -2243,14 +2243,14 @@
  • - disconnect() + disconnect
  • - publish_event() + publish_event
  • @@ -2283,6 +2283,7 @@

    Kafka publisher

    +
    @@ -2334,7 +2335,7 @@

    -disconnect() + disconnect() async @@ -2382,7 +2383,7 @@

    -publish_event(event) + publish_event(event) async @@ -2457,6 +2458,7 @@

    - streampipes.functions.broker.nats.nats_consumer + nats_consumer @@ -1571,14 +1571,14 @@
  • - disconnect() + disconnect
  • - get_message() + get_message
  • @@ -2228,7 +2228,7 @@
  • - streampipes.functions.broker.nats.nats_consumer + nats_consumer
  • @@ -2243,14 +2243,14 @@
  • - disconnect() + disconnect
  • - get_message() + get_message
  • @@ -2283,6 +2283,7 @@

    Nats consumer

    +
    @@ -2334,7 +2335,7 @@

    -disconnect() + disconnect() async @@ -2382,7 +2383,7 @@

    -get_message() + get_message()

    @@ -2430,6 +2431,7 @@

    - streampipes.functions.broker.nats.nats_publisher + nats_publisher @@ -1591,14 +1591,14 @@
  • - disconnect() + disconnect
  • - publish_event() + publish_event
  • @@ -2228,7 +2228,7 @@
  • - streampipes.functions.broker.nats.nats_publisher + nats_publisher
  • @@ -2243,14 +2243,14 @@
  • - disconnect() + disconnect
  • - publish_event() + publish_event
  • @@ -2283,6 +2283,7 @@

    Nats publisher

    +
    @@ -2334,7 +2335,7 @@

    -disconnect() + disconnect() async @@ -2382,7 +2383,7 @@

    -publish_event(event) + publish_event(event) async @@ -2457,6 +2458,7 @@

    - streampipes.functions.broker.output_collector + output_collector @@ -1379,14 +1379,14 @@
  • - collect() + collect
  • - disconnect() + disconnect
  • @@ -2226,7 +2226,7 @@
  • - streampipes.functions.broker.output_collector + output_collector
  • @@ -2241,14 +2241,14 @@
  • - collect() + collect
  • - disconnect() + disconnect
  • @@ -2281,6 +2281,7 @@

    Output collector

    +
    @@ -2300,7 +2301,7 @@

    Output collector

    -OutputCollector(data_stream) + OutputCollector(data_stream)

    @@ -2349,7 +2350,7 @@

    publisher

    The publisher instance that sends the data to StreamPipes

    @@ -2384,7 +2385,7 @@

    -collect(event) + collect(event)

    @@ -2455,7 +2456,7 @@

    -disconnect() + disconnect()

    @@ -2499,6 +2500,7 @@

    - streampipes.functions.broker.publisher + publisher @@ -1399,7 +1399,7 @@
  • - publish_event() + publish_event
  • @@ -2219,7 +2219,7 @@
  • - streampipes.functions.broker.publisher + publisher
  • @@ -2234,7 +2234,7 @@
  • - publish_event() + publish_event
  • @@ -2267,6 +2267,7 @@

    Publisher

    +
    @@ -2319,7 +2320,7 @@

    -publish_event(event) + publish_event(event) abstractmethod @@ -2395,6 +2396,7 @@

    - streampipes.functions.function_handler + function_handler @@ -1207,21 +1207,21 @@
  • - disconnect() + disconnect
  • - force_stop_functions() + force_stop_functions
  • - initializeFunctions() + initializeFunctions
  • @@ -2231,7 +2231,7 @@
  • - streampipes.functions.function_handler + function_handler
  • @@ -2246,21 +2246,21 @@
  • - disconnect() + disconnect
  • - force_stop_functions() + force_stop_functions
  • - initializeFunctions() + initializeFunctions
  • @@ -2293,6 +2293,7 @@

    Function handler

    +
    @@ -2312,7 +2313,7 @@

    Function handler

    -FunctionHandler(registration, client) + FunctionHandler(registration, client)

    @@ -2376,7 +2377,7 @@

    stream_contexts

    Map of all data stream contexts

    @@ -2390,7 +2391,7 @@

    brokers

    List of all registered brokers

    @@ -2425,7 +2426,7 @@

    -disconnect() + disconnect()

    @@ -2469,7 +2470,7 @@

    -force_stop_functions() + force_stop_functions()

    @@ -2538,7 +2539,7 @@

    -initializeFunctions() + initializeFunctions()

    @@ -2582,6 +2583,7 @@

    - streampipes.functions.registration + registration @@ -1227,14 +1227,14 @@
  • - getFunctions() + getFunctions
  • - register() + register
  • @@ -2224,7 +2224,7 @@
  • - streampipes.functions.registration + registration
  • @@ -2239,14 +2239,14 @@
  • - getFunctions() + getFunctions
  • - register() + register
  • @@ -2279,6 +2279,7 @@

    Registration

    +
    @@ -2298,7 +2299,7 @@

    Registration

    -Registration() + Registration()

    @@ -2319,7 +2320,7 @@

    - functions + functions

    List of all registered StreamPipesFunction

    @@ -2354,7 +2355,7 @@

    -getFunctions() + getFunctions()

    @@ -2403,7 +2404,7 @@

    -register(streampipes_function) + register(streampipes_function)

    @@ -2478,6 +2479,7 @@

    - streampipes.functions.streampipes_function + streampipes_function @@ -1247,49 +1247,49 @@
  • - add_output() + add_output
  • - getFunctionId() + getFunctionId
  • - onEvent() + onEvent
  • - onServiceStarted() + onServiceStarted
  • - onServiceStopped() + onServiceStopped
  • - requiredStreamIds() + requiredStreamIds
  • - stop() + stop
  • @@ -2259,7 +2259,7 @@
  • - streampipes.functions.streampipes_function + streampipes_function
  • @@ -2274,49 +2274,49 @@
  • - add_output() + add_output
  • - getFunctionId() + getFunctionId
  • - onEvent() + onEvent
  • - onServiceStarted() + onServiceStarted
  • - onServiceStopped() + onServiceStopped
  • - requiredStreamIds() + requiredStreamIds
  • - stop() + stop
  • @@ -2349,6 +2349,7 @@

    Streampipes function

    +
    @@ -2368,7 +2369,7 @@

    Streampipes function

    -StreamPipesFunction(function_definition=None) + StreamPipesFunction(function_definition=None)

    @@ -2425,7 +2426,7 @@

    output_collectors

    List of all output collectors which are created based on the provided function definitions.

    @@ -2460,7 +2461,7 @@

    -add_output(stream_id, event) + add_output(stream_id, event)

    @@ -2545,7 +2546,7 @@

    -getFunctionId() + getFunctionId()

    @@ -2593,7 +2594,7 @@

    -onEvent(event, streamId) + onEvent(event, streamId) abstractmethod @@ -2682,7 +2683,7 @@

    -onServiceStarted(context) + onServiceStarted(context) abstractmethod @@ -2757,7 +2758,7 @@

    -onServiceStopped() + onServiceStopped() abstractmethod @@ -2805,7 +2806,7 @@

    -requiredStreamIds() + requiredStreamIds()

    @@ -2853,7 +2854,7 @@

    -stop() + stop()

    @@ -2872,6 +2873,7 @@

    +

    diff --git a/docs-python/dev/reference/functions/utils/async_iter_handler/index.html b/docs-python/dev/reference/functions/utils/async_iter_handler/index.html index 226327585..55e0a4854 100644 --- a/docs-python/dev/reference/functions/utils/async_iter_handler/index.html +++ b/docs-python/dev/reference/functions/utils/async_iter_handler/index.html @@ -1654,7 +1654,7 @@
  • - streampipes.functions.utils.async_iter_handler + async_iter_handler
  • @@ -1669,14 +1669,14 @@
  • - anext() + anext
  • - combine_async_messages() + combine_async_messages
  • @@ -2226,7 +2226,7 @@
  • - streampipes.functions.utils.async_iter_handler + async_iter_handler
  • @@ -2241,14 +2241,14 @@
  • - anext() + anext
  • - combine_async_messages() + combine_async_messages
  • @@ -2281,6 +2281,7 @@

    Async iter handler

    +
    @@ -2330,7 +2331,7 @@

    -anext(stream_id, message) + anext(stream_id, message) async @@ -2424,7 +2425,7 @@

    -combine_async_messages(messages) + combine_async_messages(messages) async @@ -2504,6 +2505,7 @@

    - streampipes.functions.utils.data_stream_context + data_stream_context @@ -1689,7 +1689,7 @@
  • - add_function() + add_function
  • @@ -2219,7 +2219,7 @@
  • - streampipes.functions.utils.data_stream_context + data_stream_context
  • @@ -2234,7 +2234,7 @@
  • - add_function() + add_function
  • @@ -2267,6 +2267,7 @@

    Data stream context

    +
    @@ -2286,7 +2287,7 @@

    Data stream context

    -DataStreamContext(functions, schema, broker) + DataStreamContext(functions, schema, broker)

    @@ -2370,7 +2371,7 @@

    -add_function(function) + add_function(function)

    @@ -2441,6 +2442,7 @@

    - streampipes.functions.utils.data_stream_generator + data_stream_generator @@ -1708,7 +1708,7 @@
  • - create_data_stream() + create_data_stream
  • @@ -2213,7 +2213,7 @@
  • - streampipes.functions.utils.data_stream_generator + data_stream_generator
  • @@ -2227,7 +2227,7 @@
  • - create_data_stream() + create_data_stream
  • @@ -2255,6 +2255,7 @@

    Data stream generator

    +
    @@ -2298,7 +2299,7 @@

    STRING
    @@ -2308,7 +2309,7 @@

    BOOLEAN
    @@ -2318,7 +2319,7 @@

    DOUBLE
    @@ -2328,7 +2329,7 @@

    FLOAT
    @@ -2338,7 +2339,7 @@

    INTEGER
    @@ -2348,7 +2349,7 @@

    LONG
    @@ -2379,6 +2380,7 @@

    -create_data_stream(name, attributes, stream_id=None, broker=SupportedBroker.NATS) + create_data_stream(name, attributes, stream_id=None, broker=SupportedBroker.NATS)

    diff --git a/docs-python/dev/reference/functions/utils/function_context/index.html b/docs-python/dev/reference/functions/utils/function_context/index.html index 5dcb3b024..955ae41cc 100644 --- a/docs-python/dev/reference/functions/utils/function_context/index.html +++ b/docs-python/dev/reference/functions/utils/function_context/index.html @@ -1714,7 +1714,7 @@
  • - streampipes.functions.utils.function_context + function_context
  • @@ -1729,7 +1729,7 @@
  • - add_data_stream_schema() + add_data_stream_schema
  • @@ -2219,7 +2219,7 @@
  • - streampipes.functions.utils.function_context + function_context
  • @@ -2234,7 +2234,7 @@
  • - add_data_stream_schema() + add_data_stream_schema
  • @@ -2267,6 +2267,7 @@

    Function context

    +
    @@ -2286,7 +2287,7 @@

    Function context

    -FunctionContext(function_id, schema, client, streams) + FunctionContext(function_id, schema, client, streams)

    @@ -2384,7 +2385,7 @@

    -add_data_stream_schema(stream_id, data_stream) + add_data_stream_schema(stream_id, data_stream)

    @@ -2469,6 +2470,7 @@

    - streampipes.model.common + common @@ -1894,7 +1894,7 @@
  • - random_letters() + random_letters
  • @@ -2301,7 +2301,7 @@
  • - streampipes.model.common + common
  • @@ -2405,7 +2405,7 @@
  • - random_letters() + random_letters
  • @@ -2433,6 +2433,7 @@

    Common

    +
    @@ -2486,6 +2487,7 @@
    +
    @@ -2525,6 +2527,7 @@

    +
    @@ -2540,7 +2543,7 @@

    - Bases: BaseModel

    + Bases: BaseModel

    Basic model class used for the whole Python StreamPipes data model.

    @@ -2593,6 +2596,7 @@

    +

    @@ -2602,6 +2606,7 @@

    +
    @@ -2641,6 +2646,7 @@

    +

    @@ -2680,6 +2686,7 @@

    +

    @@ -2719,6 +2726,7 @@

    +

    @@ -2758,6 +2766,7 @@

    +

    @@ -2797,6 +2806,7 @@

    +

    @@ -2836,6 +2846,7 @@

    +

    @@ -2875,6 +2886,7 @@

    +
    @@ -2914,6 +2926,7 @@

    +
    @@ -2953,6 +2966,7 @@

    +
    @@ -2962,7 +2976,7 @@

    -random_letters(n) + random_letters(n)

    diff --git a/docs-python/dev/reference/model/container/data_lake_measures/index.html b/docs-python/dev/reference/model/container/data_lake_measures/index.html index d80e0d003..5147f2bec 100644 --- a/docs-python/dev/reference/model/container/data_lake_measures/index.html +++ b/docs-python/dev/reference/model/container/data_lake_measures/index.html @@ -1856,7 +1856,7 @@
  • - streampipes.model.container.data_lake_measures + data_lake_measures
  • @@ -2206,7 +2206,7 @@
  • - streampipes.model.container.data_lake_measures + data_lake_measures
  • @@ -2241,6 +2241,7 @@

    Data lake measures

    +
    @@ -2262,8 +2263,7 @@

    Data lake measures

    - DataLakeMeasures - + DataLakeMeasures(resources)

    @@ -2297,6 +2297,7 @@

    - streampipes.model.container.data_streams + data_streams @@ -2206,7 +2206,7 @@
  • - streampipes.model.container.data_streams + data_streams
  • @@ -2241,6 +2241,7 @@

    Data streams

    +
    @@ -2262,8 +2263,7 @@

    Data streams

    - DataStreams - + DataStreams(resources)

    @@ -2297,6 +2297,7 @@

    - streampipes.model.container.resource_container + resource_container @@ -1911,28 +1911,28 @@
  • - from_json() + from_json
  • - to_dicts() + to_dicts
  • - to_json() + to_json
  • - to_pandas() + to_pandas
  • @@ -2254,7 +2254,7 @@
  • - streampipes.model.container.resource_container + resource_container
  • @@ -2269,28 +2269,28 @@
  • - from_json() + from_json
  • - to_dicts() + to_dicts
  • - to_json() + to_json
  • - to_pandas() + to_pandas
  • @@ -2337,6 +2337,7 @@

    Resource container

    +
    @@ -2361,7 +2362,7 @@

    Resource container

    -ResourceContainer(resources) + ResourceContainer(resources)

    @@ -2422,7 +2423,7 @@

    -from_json(json_string) + from_json(json_string) classmethod @@ -2538,7 +2539,7 @@

    -to_dicts(use_source_names=False) + to_dicts(use_source_names=False)

    @@ -2619,7 +2620,7 @@

    -to_json() + to_json()

    @@ -2664,7 +2665,7 @@

    -to_pandas() + to_pandas()

    @@ -2694,7 +2695,7 @@

    TYPE: - pd.DataFrame + DataFrame

    @@ -2712,6 +2713,7 @@

    @@ -2719,7 +2721,7 @@

    -StreamPipesDataModelError(validation_error) + StreamPipesDataModelError(validation_error)

    @@ -2751,7 +2753,7 @@

    TYPE: - ValidationError + ValidationError

    @@ -2778,6 +2780,7 @@

    @@ -2785,7 +2788,7 @@

    -StreamPipesResourceContainerJSONError(container_name, json_string) + StreamPipesResourceContainerJSONError(container_name, json_string)

    @@ -2858,6 +2861,7 @@

    - streampipes.model.container.versions + versions @@ -2206,7 +2206,7 @@
  • - streampipes.model.container.versions + versions
  • @@ -2241,6 +2241,7 @@

    Versions

    +
    @@ -2262,8 +2263,7 @@

    Versions

    - Versions - + Versions(resources)

    @@ -2295,6 +2295,10 @@

    A list of resources (Version) to be contained in the ResourceContainer.

    + + TYPE: + List[Resource] +

    @@ -2320,6 +2324,7 @@

    +

    diff --git a/docs-python/dev/reference/model/resource/data_lake_measure/index.html b/docs-python/dev/reference/model/resource/data_lake_measure/index.html index a0f020fac..b778538c3 100644 --- a/docs-python/dev/reference/model/resource/data_lake_measure/index.html +++ b/docs-python/dev/reference/model/resource/data_lake_measure/index.html @@ -1996,7 +1996,7 @@
  • - streampipes.model.resource.data_lake_measure + data_lake_measure
  • @@ -2011,7 +2011,7 @@
  • - convert_to_pandas_representation() + convert_to_pandas_representation
  • @@ -2219,7 +2219,7 @@
  • - streampipes.model.resource.data_lake_measure + data_lake_measure
  • @@ -2234,7 +2234,7 @@
  • - convert_to_pandas_representation() + convert_to_pandas_representation
  • @@ -2267,6 +2267,7 @@

    Data lake measure

    +
    @@ -2322,7 +2323,7 @@

    -convert_to_pandas_representation() + convert_to_pandas_representation()

    @@ -2375,6 +2376,7 @@

    - streampipes.model.resource.data_series + data_series @@ -2031,21 +2031,21 @@
  • - convert_to_pandas_representation() + convert_to_pandas_representation
  • - from_json() + from_json
  • - to_pandas() + to_pandas
  • @@ -2233,7 +2233,7 @@
  • - streampipes.model.resource.data_series + data_series
  • @@ -2248,21 +2248,21 @@
  • - convert_to_pandas_representation() + convert_to_pandas_representation
  • - from_json() + from_json
  • - to_pandas() + to_pandas
  • @@ -2295,6 +2295,7 @@

    Data series

    +
    @@ -2330,11 +2331,13 @@

    Notes

    -
    This class will only exist temporarily in it its current appearance since
    +
    +
    + Notes +
    This class will only exist temporarily in it its current appearance since
     there are some inconsistencies in the StreamPipes API.
     
    - +
    @@ -2354,7 +2357,7 @@

    Notes -convert_to_pandas_representation() + convert_to_pandas_representation()

    @@ -2404,7 +2407,7 @@

    -from_json(json_string) + from_json(json_string) classmethod @@ -2508,7 +2511,7 @@

    -to_pandas() + to_pandas()

    @@ -2538,7 +2541,7 @@

    TYPE: - pd.DataFrame + DataFrame

    @@ -2556,6 +2559,7 @@

    - streampipes.model.resource.data_stream + data_stream @@ -2051,14 +2051,14 @@
  • - convert_to_pandas_representation() + convert_to_pandas_representation
  • - to_dict() + to_dict
  • @@ -2226,7 +2226,7 @@
  • - streampipes.model.resource.data_stream + data_stream
  • @@ -2241,14 +2241,14 @@
  • - convert_to_pandas_representation() + convert_to_pandas_representation
  • - to_dict() + to_dict
  • @@ -2281,6 +2281,7 @@

    Data stream

    +
    @@ -2300,7 +2301,7 @@

    Data stream

    -DataStream(**kwargs) + DataStream(**kwargs)

    @@ -2335,7 +2336,7 @@

    -convert_to_pandas_representation() + convert_to_pandas_representation()

    @@ -2384,7 +2385,7 @@

    -to_dict(use_source_names=True) + to_dict(use_source_names=True)

    @@ -2460,6 +2461,7 @@

    - streampipes.model.resource.exceptions + exceptions @@ -2206,7 +2206,7 @@
  • - streampipes.model.resource.exceptions + exceptions
  • @@ -2241,6 +2241,7 @@

    Exceptions

    +
    @@ -2260,7 +2261,7 @@

    Exceptions

    -StreamPipesUnsupportedDataSeries(reason=None) + StreamPipesUnsupportedDataSeries(reason=None)

    @@ -2292,6 +2293,7 @@

    +

    diff --git a/docs-python/dev/reference/model/resource/function_definition/index.html b/docs-python/dev/reference/model/resource/function_definition/index.html index f1c9127d1..ee7ca2a95 100644 --- a/docs-python/dev/reference/model/resource/function_definition/index.html +++ b/docs-python/dev/reference/model/resource/function_definition/index.html @@ -2076,7 +2076,7 @@
  • - streampipes.model.resource.function_definition + function_definition
  • @@ -2091,28 +2091,28 @@
  • - add_output_data_stream() + add_output_data_stream
  • - convert_to_pandas_representation() + convert_to_pandas_representation
  • - get_output_data_streams() + get_output_data_streams
  • - get_output_stream_ids() + get_output_stream_ids
  • @@ -2247,7 +2247,7 @@
  • - streampipes.model.resource.function_definition + function_definition
  • @@ -2262,28 +2262,28 @@
  • - add_output_data_stream() + add_output_data_stream
  • - convert_to_pandas_representation() + convert_to_pandas_representation
  • - get_output_data_streams() + get_output_data_streams
  • - get_output_stream_ids() + get_output_stream_ids
  • @@ -2323,6 +2323,7 @@

    Function definition

    +
    @@ -2401,7 +2402,7 @@

    - output_data_streams + output_data_streams

    Map off all output data streams added to the function definition

    @@ -2436,7 +2437,7 @@

    -add_output_data_stream(data_stream) + add_output_data_stream(data_stream)

    @@ -2511,7 +2512,7 @@

    -convert_to_pandas_representation() + convert_to_pandas_representation()

    @@ -2561,7 +2562,7 @@

    -get_output_data_streams() + get_output_data_streams()

    @@ -2609,7 +2610,7 @@

    -get_output_stream_ids() + get_output_stream_ids()

    @@ -2657,6 +2658,7 @@

    @@ -2730,6 +2732,7 @@

    - streampipes.model.resource.query_result + query_result @@ -2111,14 +2111,14 @@
  • - convert_to_pandas_representation() + convert_to_pandas_representation
  • - to_pandas() + to_pandas
  • @@ -2226,7 +2226,7 @@
  • - streampipes.model.resource.query_result + query_result
  • @@ -2241,14 +2241,14 @@
  • - convert_to_pandas_representation() + convert_to_pandas_representation
  • - to_pandas() + to_pandas
  • @@ -2281,6 +2281,7 @@

    Query result

    +
    @@ -2336,7 +2337,7 @@

    -convert_to_pandas_representation() + convert_to_pandas_representation()

    @@ -2407,7 +2408,7 @@

    -to_pandas() + to_pandas()

    @@ -2437,7 +2438,7 @@

    TYPE: - pd.DataFrame + DataFrame

    @@ -2455,6 +2456,7 @@

    - streampipes.model.resource.resource + resource @@ -2131,14 +2131,14 @@
  • - convert_to_pandas_representation() + convert_to_pandas_representation
  • - to_dict() + to_dict
  • @@ -2226,7 +2226,7 @@
  • - streampipes.model.resource.resource + resource
  • @@ -2241,14 +2241,14 @@
  • - convert_to_pandas_representation() + convert_to_pandas_representation
  • - to_dict() + to_dict
  • @@ -2281,6 +2281,7 @@

    Resource

    +
    @@ -2339,7 +2340,7 @@

    -convert_to_pandas_representation() + convert_to_pandas_representation() abstractmethod @@ -2392,7 +2393,7 @@

    -to_dict(use_source_names=True) + to_dict(use_source_names=True)

    @@ -2468,6 +2469,7 @@

    - streampipes.model.resource.version + version @@ -2149,7 +2149,14 @@
  • - convert_to_pandas_representation() + convert_to_pandas_representation + + +
  • + +
  • + + validate_backend_version
  • @@ -2217,7 +2224,7 @@
  • - streampipes.model.resource.version + version
  • @@ -2232,7 +2239,14 @@
  • - convert_to_pandas_representation() + convert_to_pandas_representation + + +
  • + +
  • + + validate_backend_version
  • @@ -2265,6 +2279,7 @@

    Version

    +
    @@ -2308,7 +2323,7 @@

    - backend_version + backend_version

    version of the StreamPipes backend the client is connected to

    @@ -2343,7 +2358,7 @@

    -convert_to_pandas_representation() + convert_to_pandas_representation()

    @@ -2358,11 +2373,33 @@

    + + + +

    + validate_backend_version(backend_version) + +

    + + +
    + +

    Validates the backend version of the StreamPipes. +Sets 'development' if none is returned since this the behavior of StreamPipes backend running +in development mode.

    +
    + + +

    +
    + +

    diff --git a/docs-python/dev/scripts/gen_ref_pages/index.html b/docs-python/dev/scripts/gen_ref_pages/index.html index 543a5d08f..d5f0f76b6 100644 --- a/docs-python/dev/scripts/gen_ref_pages/index.html +++ b/docs-python/dev/scripts/gen_ref_pages/index.html @@ -3168,7 +3168,7 @@

    Gen ref pages

    init_mathjax();
    -

    +
    +
    +