Interface with all methods available both to the pipeline runners and the Data Science API.

Methods

create()

create and save an object on the server

Name	Type	Default	Description
obj			object from a supported entity
return: object created

create_component()

create a component based on its ID.

Name	Type	Default	Description
component	SolutionComponent

delete()

delete an object on the server

Name	Type	Default	Description
obj			object from a supported entity

delete_component()

delete component

Name	Type	Default	Description
component_id	UUID

download_file()

download a model extra file from the repository.

Name	Type	Default	Description
model	ModelInfo	None	model (ModelInfo), alternatively can use identifier
file	ModelFile	None	file (ModelFile), alternatively can use path
identifier	str	None	identifier including alias of the model.
path	str	None	path name of the file including the extension.
return: bytes content.

download_model()

download a model image directly from the repository, auto-select alias if necessary.

Name	Type	Default	Description
identifier	str		exact identifier including alias of the model or no alias to auto-select active version.
return: ModelInfo with trained_model loaded, extra file must be downloaded separately.

get()

get record content from DS API.

get will look first for obj then for id then for key (e.g. if id and key specified, key is ignored )

Name	Type	Default	Description
obj		None	a wizata_dsapi.`<Entity>()` with UUID set - fetch using technical UUID
id	UUID	None	a UUID of a specific object (use in combination of entity)
key	str	None	a logical key of a specific object (e.g. hardware id for DataPoint and Twin (use in combination of entity)
entity		None	plural name of the entity or class (use in combination of entity)(e.g. scripts, plots, mlmodels, dataframes...)
return: object with all properties or None if not found.

get_business_labels()

get a name / uuid dictionary with all business labels in platform.

get_components()

get components

Name	Type	Default	Description
label_id	UUID	None	filter on a specific label
twin_id	UUID	None	filter on a specific twin
template_id	UUID	None	filter on a specific template
owner_id	UUID	None	filter on a specific owner_id
organization_only	bool	False	work only with organization components (by default - False)
name	str	None	filter on a specific name (contains)

get_datapoint_mappings()

get datapoint mapping from a registration.

Name	Type	Default	Description
registration

get_registrations()

retrieve all registrations for

Name	Type	Default	Description
template			template object, UUID or str key.
return: list of twin registration.

lists()

lists all elements of a specific entity.

Name	Type	Default	Description
entity			plural name of the entity or class (e.g. scripts, plots, mlmodels, dataframes...)
return: list of all elements with at least the id property.

query()

Query a dataframe from timeseries DB.

Name	Type	Default	Description
datapoints	list	None	list of datapoints to fetch.
start	datetime	None	start datetime of range to fetch
end	datetime	None	end datetime of range to fetch
interval	int	None	interval in milliseconds.
agg_method	str	mean
template	str	None	template to fetch.
twin	str	None	hardware ID of twin to fetch based on template.
null	str	None	default 'drop' will drop NaN values. If not intended behavior please set it to 'ignore' or 'all'.
filters	dict	None	dict of filters.
options	dict	None	dict of options.
group	dict	None	can be used to set group system and event retrieving instructions.
field	str	None	by default 'value' if none, can be used to retrieve 'eventId'
bucket	str	None	specify on which bucket the query applies.
tags	dict	None	dict of tags to filter on.
return: dataframe

search_datapoints()

get datapoints with a paged query.

Name	Type	Default	Description
page	int	1	numero of the page - default 1.
size	int	20	quantity per page - default 20 max 100.
sort	str	id	column to sort results - default id.
direction	str	asc	sorting direction by default asc, accept also desc.
hardware_id	str	None	filter on a specific hardware ID name or partial name.
categories	list	None	list of UUID or Category.
business_types	list	None	list of BusinessType or str.
twin		None	uuid or Twin element to search datapoints.
recursive	bool	False	set to True in combination of a twin to look inside all sub-twins recursively.
return: PagedQueryResults, check total for number of potential results and results for the list of entity.

search_insights()

get insights with a paged query.

Name	Type	Default	Description
page	int	1	numero of the page - default 1.
size	int	20	quantity per page - default 20 max 100.
sort	str	id	column to sort results - default id.
direction	str	asc	sorting direction by default asc, accept also desc.
datapoint_id	str	None	id of the datapoint on which filtering the insights.
twin_id	str	None	id of the twin on which filtering the insights.
component_id	list	None	id of the component on which filtering the insights.
return: PagedQueryResults, check total for number of potential results and results for the list of entity.

search_twins()

get twins with a paged query.

Name	Type	Default	Description
page	int	1	numero of the page - default 1.
size	int	20	quantity per page - default 20 max 100.
sort	str	id	column to sort results - default id.
direction	str	asc	sorting direction by default asc, accept also desc.
hardware_id	str	None	filter on a specific hardware ID name or partial name.
name	str	None	name or part of twin name.
parents	list	None	list of all possible parents (Twin, UUID, or str UUID).
return: PagedQueryResults, check total for number of potential results and results for the list of entity.

send_alerts()

send alerts through backend

Name	Type	Default
message	str
recipients	list
alert_type	AlertType	AlertType.SMS
subject	str
cc	list	None

update()

update and save an object on the server

Name	Type	Default	Description
obj			object from a supported entity

update_component()

update a component based on its ID.

Name	Type	Default	Description
component	SolutionComponent

upload_file()

upload a model extra file to the repository.

please use upload_model for a trained_model

Name	Type	Default	Description
content			the bytes content of the file.
model	ModelInfo	None	model (ModelInfo), alternatively can use identifier
file	ModelFile	None	file (ModelFile), alternatively can use path
identifier	str	None	identifier including alias of the model.
path	str	None	path name of the file including the extension.
return: bytes content.

upload_model()

upload a model within the model repository.

by default use model_info.trained_model and convert it to a pickle
for already torch or pickle please pass the bytes_content
model_info.file_format must be set properly to 'pkl' or 'pt'

Name	Type	Default	Description
model_info	ModelInfo		model info, with at least key (+twin, +property, +alias) and trained_model.
bytes_content		None	bytes[] of your torch or pickle model.