FLOJOY_CLOUD_DOWNLOAD
Download a measurement from Flojoy Cloud (beta). Params: measurement_id : str The data measurement id of the data to be downloaded from Flojoy Cloud. Returns: out : DataContainer The downloaded DataContainer will be returned as it is.
Python Code
import os
import logging
from flojoy import (
DataContainer,
flojoy,
get_env_var,
node_preflight,
DataFrame,
Boolean,
)
import flojoy_cloud
import pandas as pd
FLOJOY_CLOUD_URI: str = os.environ.get("FLOJOY_CLOUD_URI") or "https://cloud.flojoy.ai"
@node_preflight
def preflight():
api_key = get_env_var("FLOJOY_CLOUD_KEY")
if api_key is None:
raise KeyError(
"Flojoy Cloud key is not found! You can set it under Settings -> Environment Variables."
)
@flojoy
def FLOJOY_CLOUD_DOWNLOAD(
measurement_id: str,
) -> DataContainer:
"""Download a measurement from Flojoy Cloud (beta).
Parameters
----------
measurement_id : str
The data measurement id of the data to be downloaded from Flojoy Cloud.
Returns
-------
DataContainer
The downloaded DataContainer will be returned as it is.
"""
api_key = get_env_var("FLOJOY_CLOUD_KEY")
if api_key is None:
raise KeyError(
"Flojoy Cloud key is not found! You can set it under Settings -> Environment Variables."
)
cloud = flojoy_cloud.FlojoyCloud(workspace_secret=api_key)
measurement = cloud.get_measurement(measurement_id)
logging.info(measurement)
match measurement.data["type"]:
case "dataframe":
return DataFrame(pd.DataFrame(measurement.data["value"]))
case "boolean":
return Boolean(measurement.data["value"])
case _:
raise NotImplementedError(
f"Type {measurement.data['type']} is not implemented"
)
Example
Having problems with this example app? Join our Discord community and we will help you out!
This is the exact same as the default example app, except we will stream the result of the ADD node to Flojoy Cloud