Types Mapping Ultipa and Python

Mapping Methods

The get() or alias() method of the UltipaResponse class returns a DataItem, which embeds the query result. You should use the as<Type>() method of DataItem to cast the result to the appropriate driver type.

response = Conn.uql("find().nodes() as n return n{*} limit 5")
nodeList = response.alias("n").asNodes()

The result n coming from the database contains five nodes, each of the NODE type. The asNodes() method converts them as a list of Node objects.

Type mapping methods available on DataItem:

Driver Types

Objects of all driver types support getter methods to retrieve the value of a field and setter methods to set the value of a field, even if they are not explicitly listed below.

Node

A Node object has the following fields:

Methods on a Node object:

response = Conn.uql("find().nodes() as n return n{*} limit 5")
nodes = response.alias("n").asNodes()

print("ID of the 1st node:", nodes[0].getID())
print("Store name of the 1st node", nodes[0].get("storeName"))

ID of the 1st node: 47370-257954
Store name of the 1st node: Meritxell, 96

Edge

An Edge object has the following fields:

Methods on an Edge object:

response = Conn.uql("find().edges() as e return e{*} limit 5")
edges = response.alias("e").asEdges()

print("Values of the 1st edge:", edges[0].getValues())

Values of the 1st edge: {'distanceMeters': 20, 'duration': '21s', 'staticDuration': '25s', 'travelMode': 'Walk', 'transportationCost': 46}

Path

A Path object has the following fields:

Methods on a Path object:

response = Conn.uql("n().e()[:2].n() as paths return paths{*} limit 5")
paths = response.alias("paths").asPaths()

print("Length of the 1st path:", paths[0].length())

print("Edges in the 1st path:")
edges = paths[0].getEdges()
for edge in edges:
    print(edge)

print("Information of the 2nd node in the 1st path:")
nodes = paths[0].getNodes()
print(nodes[1])

Length of the 1st path: 2
Edges in the 1st path: 
{'schema': 'transport', 'from_id': '15219-158845', 'from_uuid': 20, 'to_id': '47370-257954', 'to_uuid': 1, 'values': {'distanceMeters': 10521283, 'duration': '527864s', 'staticDuration': '52606s', 'travelMode': 'Airplane', 'transportationCost': 21043}, 'uuid': 591}
{'schema': 'transport', 'from_id': '15474-156010', 'from_uuid': 21, 'to_id': '15219-158845', 'to_uuid': 20, 'values': {'distanceMeters': 233389, 'duration': '13469s', 'staticDuration': '1167s', 'travelMode': 'Airplane', 'transportationCost': 467}, 'uuid': 599}
Information of the 2nd node in the 1st path: 
{'id': '15219-158845', 'schema': 'warehouse', 'values': {'brand': 'Starbucks', 'storeName': 'Las Palmas', 'ownershipType': 'Licensed', 'city': 'Pilar', 'provinceState': 'B', 'timezone': 'GMT-03:00 America/Argentina/Bu', 'point': 'POINT(-33.390000 -60.220000)'}, 'uuid': 20}

Graph

A Graph object has the following fields:

response = Conn.uql("n(as n1).re(as e).n(as n2).limit(3) with toGraph(collect(n1), collect(n2), collect(e)) as graph return graph", requestConfig)
graph = response.alias("graph").asGraph()

print("Node IDs:")
nodes = graph.node_table
for node in nodes:
    print(node.getID())

print("Edge UUIDs:")
edges = graph.edge_table
for edge in edges:
    print(edge.getUUID())

Node IDs:
24604-238367
34291-80114
47370-257954
29791-255373
23359-229184
Edge UUIDs:
344
320
346

GraphSet

A GraphSet object has the following fields:

response = Conn.uql("show().graph()")
graphs = response.alias("_graph").asGraphSets()
for graph in graphs:
    if graph.status == "UNMOUNTED":
        print(graph.name)

DFS_EG
cyber
netflow

Schema

A Schema object has the following fields:

response = Conn.uql("show().node_schema()")
schemas = response.alias("_nodeSchema").asSchemas()
for schema in schemas:
    print(schema.name, "has", schema.total, "nodes")

default has 0 nodes
member has 7 nodes
organization has 19 nodes

Property

A Property object has the following fields:

response = Conn.uql("show().property()")
properties = response.alias("_nodeProperty").asProperties()
for property in properties:
    print(property.name)

title
profile
age
name
logo

Algo

An Algo object has the following fields:

response = Conn.uql("show().algo()")
algos = response.alias("_algoList").asAlgos()
print(algos[0])

{'name': 'celf', 'description': 'celf', 'version': '1.0.0', 'result_opt': '25', 'parameters': {'seedSetSize': 'size_t,optional,1 as default', 'monteCarloSimulations': 'size_t,optional, 1000 as default', 'propagationProbability': 'float,optional, 0.1 as default'}, 'write_to_db_parameters': {}, 'write_to_file_parameters': {'filename': 'set file name'}}

Exta

An exta is a custom algorithm developed by users.

An Exta object has the following fields:

response = Conn.uql("show().exta()")
extas = response.alias("_extaList").asExtas()
print(extas[0].name)

page_rank

Index

An Index object has the following fields:

response = Conn.uql("show().index()")
indexList = response.alias("_nodeIndex").asIndexes()

for index in indexList:
    print(index.schema, index.properties, index.size)

account name 0
movie name 2526

response = Conn.uql("show().fulltext()")
indexList = response.alias("_edgeFulltext").asIndexes()

for index in indexList:
    print(index.schema, index.properties, index.schema)

contentFull content review

Privilege

A Privilege object has the following fields:

response = Conn.uql("show().privilege()")
privilege = response.alias("_privilege").asPrivilege()
print(privilege.systemPrivileges)

["TRUNCATE","COMPACT","CREATE_GRAPH","SHOW_GRAPH","DROP_GRAPH","ALTER_GRAPH","MOUNT_GRAPH","UNMOUNT_GRAPH","TOP","KILL","STAT","SHOW_POLICY","CREATE_POLICY","DROP_POLICY","ALTER_POLICY","SHOW_USER","CREATE_USER","DROP_USER","ALTER_USER","GRANT","REVOKE","SHOW_PRIVILEGE"]

Policy

A Policy object has the following fields:

response = Conn.uql("show().policy()")
policyList = response.alias("_policy").asPolicies()

for policy in policyList:
    print(policy.name)

manager
operator

User

A User object has the following fields:

response = Conn.uql("show().user('Tester')")
user = response.alias("_user").asUsers()

print(user.toJSON())

{"create": 1721974206, "graphPrivileges": "{}", "policies": "[]", "propertyPrivileges": "{\"node\":{\"read\":[],\"write\":[[\"miniCircle\",\"account\",\"name\"]],\"deny\":[]},\"edge\":{\"read\":[],\"write\":[],\"deny\":[]}}", "systemPrivileges": "[]", "username": "Tester"}

Stats

A Stats object has the following fields:

response = Conn.uql("stats()")
stats = response.get(0).asStats()
print("CPU usage (%):", stats.cpuUsage)
print("Memory usage:", stats.memUsage)

CPU usage (%): 5.415697
Memory usage: 9292.265625

Process

A Process object has the following fields:

requestConfig = RequestConfig(graphName="amz")

response = Conn.uql("top()", requestConfig)
processList = response.alias("_top").asProcesses()
for process in processList:
    print(process.processId)

a_2_569_2
a_3_367_1

Task

A Task object has the following fields:

requestConfig = RequestConfig(graphName="miniCircle")

response = Conn.uql("show().task()", requestConfig)
tasks = response.alias("_task").asTasks()
print(tasks[0].task_info)
print(tasks[0].param)
print(tasks[0].result)

{'task_id': 77954, 'server_id': 2, 'algo_name': 'louvain', 'start_time': 1728543848, 'writing_start_time': 1728543848, 'end_time': 1728543848, 'time_cost': 0, 'TASK_STATUS': 3, 'return_type': <ultipa.types.types_response.Return_Type object at 0x0000025E53C0F940>}
{"phase1_loop_num":"20","min_modularity_increase":"0.001"}
{'community_count': '10', 'modularity': '0.535017', 'result_files': 'communityID,ids,num'}

Table

A Table object has the following fields:

Methods on a Table object:

response = Conn.uql("find().nodes() as n return table(n._id, n._uuid) as myTable limit 5")
table = response.alias("myTable").asTable()
rows = table.headerToDicts()
print("2nd row in table:", rows[1])

2nd row in table: {'n._id': 'u604510', 'n._uuid': 2}

Attr

A Attr object has the following fields:

response = Conn.uql("find().nodes({@ad}) as n return n.brand limit 5")
attr = response.alias("n.brand").asAttr()
print(attr.values)

[14655, 14655, 14655, 14655, 434760]