GraphManagementApI¶

All URIs are relative to {INTERACTIVE_ADMIN_ENDPOINT}

Method	HTTP request	Description
ListGraphs	GET /v1/graph	List all graphs’ metadata
CreateGraph	POST /v1/graph	Create a new graph
GetGraphMeta	GET /v1/graph/{graph_id}	Get the metadata for a graph identified by the specified graphId
GetGraphSchema	GET /v1/graph/{graph_id}/schema	Get the schema for a graph identified by the specified graphId
DeleteGraph	DELETE /v1/graph/{graph_id}	Remove the graph identified by the specified graphId
GetGraphStatistics	GET /v1/graph/{graph_id}/statistics	Get the statistics for a graph identified by the specified graphId
BulkLoading	POST /v1/graph/{graph_id}/dataloading	Create a bulk loading job for the graph identified by the specified graphId

CreateGraph¶

Result[CreateGraphResponse] create_graph(create_graph_request)

Create a new graph

Example¶

from gs_interactive.client.driver import Driver
from gs_interactive.client.session import Session
from gs_interactive.models import *

test_graph_def = {
    "name": "test_graph",
    "description": "This is a test graph",
    "schema": {
        "vertex_types": [
            {
                "type_name": "person",
                "properties": [
                    {
                        "property_name": "id",
                        "property_type": {"primitive_type": "DT_SIGNED_INT64"},
                    },
                    {
                        "property_name": "name",
                        "property_type": {"string": {"long_text": ""}},
                    },
                    {
                        "property_name": "age",
                        "property_type": {"primitive_type": "DT_SIGNED_INT32"},
                    },
                ],
                "primary_keys": ["id"],
            }
        ],
        "edge_types": [
            {
                "type_name": "knows",
                "vertex_type_pair_relations": [
                    {
                        "source_vertex": "person",
                        "destination_vertex": "person",
                        "relation": "MANY_TO_MANY",
                    }
                ],
                "properties": [
                    {
                        "property_name": "weight",
                        "property_type": {"primitive_type": "DT_DOUBLE"},
                    }
                ],
                "primary_keys": [],
            }
        ],
    },
}
driver = Driver()
sess = driver.session()
create_graph_request = CreateGraphRequest.from_dict(test_graph_def)
resp = sess.create_graph(create_graph_request)
assert resp.is_ok()
graph_id = resp.get_value().graph_id
print("Graph id: ", graph_id)

Parameters¶

Name	Type	Description	Notes
create_graph_request	CreateGraphRequest

Return type¶

Reesult[CreateGraphResponse]

Authorization¶

No authorization required

HTTP request headers¶

Content-Type: application/json
Accept: application/json

HTTP response details¶

Status code	Description	Response headers
200	successful operation	-
400	BadRequest	-
500	Internal error	-

[Back to top] [Back to API list] [Back to Model list] [Back to python_sdk]

DeleteGraph¶

Result[str] delete_graph(graph_id)

Delete a graph by id.

Example¶

resp = sess.delete_graph(graph_id)
assert resp.is_ok()
print("graph deleted: ", resp)

Parameters¶

Name	Type	Description	Notes
graph_id	str	The name of graph to delete

Return type¶

Result[str]

Authorization¶

No authorization required

HTTP request headers¶

Content-Type: Not defined
Accept: application/json

HTTP response details¶

Status code	Description	Response headers
200	Successful operation	-
404	Not Found	-
500	Internal Error	-

[Back to top] [Back to API list] [Back to Model list] [Back to python_sdk]

GetGraphMeta¶

GetGraphResponse get_graph(graph_id)

Get the metadata of a graph.

Example¶

resp = sess.get_graph_meta(graph_id)
assert resp.is_ok()
print("Got metadata for graph {} is {}", graph_id, resp)

Parameters¶

Name	Type	Description	Notes
graph_id	str	The id of graph

Return type¶

Result[GetGraphResponse]

Authorization¶

No authorization required

HTTP request headers¶

Content-Type: Not defined
Accept: application/json

HTTP response details¶

Status code	Description	Response headers
200	Successful operation	-
404	Not found	-

[Back to top] [Back to API list] [Back to Model list] [Back to python_sdk]

GetGraphStatistics¶

GetGraphStatisticsResponse get_graph_statistic(graph_id)

Get the statics info of a graph, including number of vertices for each label, number of edges for each label.

Example¶

resp = sess.get_graph_statistics(graph_id)
assert resp.is_ok()
print("Got statistics for graph {} is {}", graph_id, resp)

Parameters¶

Name	Type	Description	Notes
graph_id	str	The id of graph to get statistics

Return type¶

Result[GetGraphStatisticsResponse]

Authorization¶

No authorization required

HTTP request headers¶

Content-Type: Not defined
Accept: application/json

HTTP response details¶

Status code	Description	Response headers
200	successful operation	-
500	Server Internal Error	-
404	Not Found	-
503	Service Unavailable	-

[Back to top] [Back to API list] [Back to Model list] [Back to python_sdk]

GetGraphSchema¶

Result[GetGraphSchemaResponse] get_graph_schema(graph_id)

Get the schema of the graph by graph_id.

Example¶

resp = sess.get_graph_schema(graph_id)
assert resp.is_ok()
print("Got schema for graph {} is {}", graph_id, resp)

Parameters¶

Name	Type	Description	Notes
graph_id	str	The name of graph to delete

Return type¶

Result[GetGraphSchemaResponse]

Authorization¶

No authorization required

HTTP request headers¶

Content-Type: Not defined
Accept: application/json

HTTP response details¶

Status code	Description	Response headers
200	successful operation	-

[Back to top] [Back to API list] [Back to Model list] [Back to python_sdk]

ListGraphs¶

Result[List[GetGraphResponse]] list_graphs()

List all graphs

Example¶

resp = sess.list_graphs()
assert resp.is_ok()
print("List all graphs", resp)

Parameters¶

This endpoint does not need any parameter.

Return type¶

Result[List[GetGraphResponse]]

Authorization¶

No authorization required

HTTP request headers¶

Content-Type: Not defined
Accept: application/json

HTTP response details¶

Status code	Description	Response headers
200	Successful operation	-

[Back to top] [Back to API list] [Back to Model list] [Back to python_sdk]

BulkLoading¶

Result[JobResponse] bulk_loading(graph_id, schema_mapping)

Create a dataloading job

Example¶

test_graph_datasource = {
    "vertex_mappings": [
        {
            "type_name": "person",
            "inputs": ["@/path/to/person.csv"],
            "column_mappings": [
                {"column": {"index": 0, "name": "id"}, "property": "id"},
                {"column": {"index": 1, "name": "name"}, "property": "name"},
                {"column": {"index": 2, "name": "age"}, "property": "age"},
            ],
        }
    ],
    "edge_mappings": [
        {
            "type_triplet": {
                "edge": "knows",
                "source_vertex": "person",
                "destination_vertex": "person",
            },
            "inputs": [
                "@/path/to/person_knows_person.csv"
            ],
            "source_vertex_mappings": [
                {"column": {"index": 0, "name": "person.id"}, "property": "id"}
            ],
            "destination_vertex_mappings": [
                {"column": {"index": 1, "name": "person.id"}, "property": "id"}
            ],
            "column_mappings": [
                {"column": {"index": 2, "name": "weight"}, "property": "weight"}
            ],
        }
    ],
}
bulk_load_request = SchemaMapping.from_dict(test_graph_datasource)
resp = sess.bulk_loading(graph_id, bulk_load_request)
assert resp.is_ok()
job_id = resp.get_value().job_id
print("job id ", job_id)

Parameters¶

Name	Type	Description	Notes
graph_id	str	The name of graph to do bulk loading.
schema_mapping	SchemaMapping

Return type¶

Result[JobResponse]

Authorization¶

No authorization required

HTTP request headers¶

Content-Type: application/json
Accept: application/json

HTTP response details¶

Status code	Description	Response headers
200	successful operation	-

[Back to top] [Back to API list] [Back to Model list] [Back to python_sdk]