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

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

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

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

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

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

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

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]