Méthodes de Mapping

La méthode get() ou alias() de la classe UltipaResponse renvoie un DataItem, qui intègre le résultat de la requête. Vous devez utiliser la méthode as<Type>() de DataItem pour convertir le résultat au type de pilote approprié.

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

Le résultat n provenant de la base de données contient cinq nodes, chacun de type NODE. La méthode asNodes() les convertit en une liste d'objets Node.

Méthodes de mappage de type disponibles sur DataItem:

Types de Pilote

Les objets de tous types de pilotes supportent les méthodes getter pour récupérer la valeur d'un champ et les méthodes setter pour définir la valeur d'un champ, même s'ils ne sont pas explicitement listés ci-dessous.

Node

Un objet Node possède les champs suivants:

Méthodes sur un objet Node:

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

print("ID du 1er node:", nodes[0].getID())
print("Nom du magasin du 1er node", nodes[0].get("storeName"))

ID du 1er node: 47370-257954
Nom du magasin du 1er node: Meritxell, 96

Edge

Un objet Edge possède les champs suivants:

Méthodes sur un objet Edge:

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

print("Valeurs du 1er edge:", edges[0].getValues())

Valeurs du 1er edge: {'distanceMeters': 20, 'duration': '21s', 'staticDuration': '25s', 'travelMode': 'Walk', 'transportationCost': 46}

Path

Un objet Path possède les champs suivants:

Méthodes sur un objet Path:

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

print("Longueur du 1er path:", paths[0].length())

print("Edges dans le 1er path:")
edges = paths[0].getEdges()
for edge in edges:
    print(edge)

print("Informations du 2e node dans le 1er path:")
nodes = paths[0].getNodes()
print(nodes[1])

Longueur du 1er path: 2
Edges dans le 1er 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}
Informations du 2e node dans le 1er 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

Un objet Graph possède les champs suivants:

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("ID des nodes:")
nodes = graph.node_table
for node in nodes:
    print(node.getID())

print("UUID des edges:")
edges = graph.edge_table
for edge in edges:
    print(edge.getUUID())

ID des nodes:
24604-238367
34291-80114
47370-257954
29791-255373
23359-229184
UUID des edges:
344
320
346

GraphSet

Un objet GraphSet possède les champs suivants:

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

Un objet Schema possède les champs suivants:

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

default a 0 nodes
member a 7 nodes
organization a 19 nodes

Property

Un objet Property possède les champs suivants:

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

title
profile
age
name
logo

Algo

Un objet Algo possède les champs suivants:

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

Un exta est un algorithme personnalisé développé par les utilisateurs.

Un objet Exta possède les champs suivants:

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

page_rank

Index

Un objet Index possède les champs suivants:

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

Un objet Privilege possède les champs suivants:

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

Un objet Policy possède les champs suivants:

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

for policy in policyList:
    print(policy.name)

manager
operator

User

Un objet User possède les champs suivants:

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

Un objet Stats possède les champs suivants:

response = Conn.uql("stats()")
stats = response.get(0).asStats()
print("Utilisation CPU (%):", stats.cpuUsage)
print("Utilisation de la mémoire:", stats.memUsage)

Utilisation CPU (%): 5.415697
Utilisation de la mémoire: 9292.265625

Process

Un objet Process possède les champs suivants:

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

Un objet Task possède les champs suivants:

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

Un objet Table possède les champs suivants:

Méthodes sur un objet Table:

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("2e ligne dans la table:", rows[1])

2e ligne dans la table: {'n._id': 'u604510', 'n._uuid': 2}

Attr

Un objet Attr possède les champs suivants:

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]