semtk3.nodegroupexecclient module

class semtk3.nodegroupexecclient.NodegroupExecClient(serverURL, status_client=None, results_client=None)

Bases: semtk3.semtkasyncclient.SemTkAsyncClient

USE_NODEGROUP_CONN = '{"name": "%NODEGROUP%","domain": "%NODEGROUP%","model": [],"data": []}'

exec_async_dispatch_filter_by_id(nodegroup_id, target_obj_sparql_id, override_conn_json=None, limit_override=None, offset_override=None, runtime_constraints=None, edc_constraints=None, flags=None)

execute a select by nodegroup id returns: the table thorws: exception otherwise

exec_async_dispatch_raw_sparql(sparql, override_conn_json=None)

execute a select by nodegroup id returns: the table thorws: exception otherwise

exec_async_dispatch_select_by_id(nodegroup_id, override_conn_json=None, limit_override=None, offset_override=None, runtime_constraints=None, edc_constraints=None, flags=None)

execute a select by nodegroup id returns: the table thorws: exception otherwise

exec_async_ingest_from_csv(nodegroup_id, csv_str, override_conn_json=None)

nodegroup_id - from nodegroup store csv_str - data, e.g. from: open(‘data.csv’, ‘r’).read() override_conn_json - string with json of a different connection

exec_dispatch_clear_graph(conn, model_or_data, index)

execute clear graph returns: message,

some text

throws: exception otherwise

exec_get_runtime_constraints_by_id(nodegroup_id)

execute a select by nodegroup id returns: valueId, itemType, valueType

?sparqlId PROPERTYITEM INT|STRING|FLOAT etc. ?sparqlId2 NODE NODE_URI

throws: exception otherwise