semtk3.nodegroupexecclient module

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

Bases: SemTkAsyncClient

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

exec_async_dispatch_count_by_id(nodegroup_id, override_conn_json_str=None, limit_override=None, offset_override=None, runtime_constraints=None, edc_constraints=None, flags=None)

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

exec_async_dispatch_filter_by_id(nodegroup_id, target_obj_sparql_id, override_conn_json_str=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_query_by_id(nodegroup_id, override_conn_json_str=None, limit_override=None, offset_override=None, runtime_constraints=None, edc_constraints=None, flags=None, query_type=None, result_type=None)

execute default query type nodegroup id returns: One of: table, json, integer thorws: exception otherwise

exec_async_dispatch_query_from_nodegroup(nodegroup_str, override_conn_json_str=None, runtime_constraints=None, edc_constraints=None, flags=None, query_type=None, result_type=None)

execute default query type nodegroup id returns: One of: table, json, integer thorws: exception otherwise

exec_async_dispatch_raw_sparql(sparql, override_conn_json_str=None)

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

exec_async_dispatch_select_by_id(nodegroup_id, override_conn_json_str=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_str=None)

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

returns status,warnings where status is always a string and warnings might be “”

exec_copy_graph(from_server, from_server_type, from_graph, to_server, to_server_type, to_graph, user_name='no_user', password='no_password')

exec_dispatch_clear_graph(conn, model_or_data, index)

execute clear graph returns: message,

some text

throws: exception otherwise

exec_dispatch_combine_entities(target_uri, duplicate_uri, delete_predicates_from_target, delete_predicates_from_duplicate, conn_json_str)

exec_dispatch_combine_entities_in_conn(same_as_class_uri, target_prop_uri, duplicate_prop_uri, delete_predicates_from_target, delete_predicates_from_duplicate, conn_json_str)

exec_dispatch_combine_entities_table(csv_str, target_col_prop_dict, duplicate_col_prop_dict, delete_predicates_from_target, delete_predicates_from_duplicate, conn_json_str)

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