Camel.storages.graph storages.nebula graph

​

NebulaGraph

class NebulaGraph(BaseGraphStorage):

​

init

def __init__(
    self,
    host,
    username,
    password,
    space,
    port = 9669,
    timeout = 10000
):

• host (str): The host address of the NebulaGraph service.
• username (str): The username for authentication.
• password (str): The password for authentication.
• space (str): The graph space to use. If it doesn’t exist, a new one will be created.
• port (int, optional): The port number for the connection. (default: :obj:9669)
• timeout (int, optional): The connection timeout in milliseconds. (default: :obj:10000)

​

_init_connection_pool

def _init_connection_pool(self):

​

_get_session

def _get_session(self):

​

get_client

def get_client(self):

​

query

def query(self, query: str):

• query (str): The Cypher-like query to be executed.

​

get_relationship_types

def get_relationship_types(self):

​

add_graph_elements

def add_graph_elements(self, graph_elements: List[GraphElement]):

• graph_elements (List[GraphElement]): A list of graph elements containing nodes and relationships.

​

ensure_edge_type_exists

def ensure_edge_type_exists(self, edge_type: str, time_label: Optional[str] = None):

• edge_type (str): The name of the edge type to be created.
• time_label (str, optional): A specific timestamp to set as the default value for the time label property. If not provided, no timestamp will be added. (default: :obj:None)

​

ensure_tag_exists

def ensure_tag_exists(self, tag_name: str, time_label: Optional[str] = None):

• tag_name (str): The name of the tag to be created.
• time_label (str, optional): A specific timestamp to set as the default value for the time label property. If not provided, no timestamp will be added. (default: :obj:None)

​

add_node

def add_node(
    self,
    node_id: str,
    tag_name: str,
    time_label: Optional[str] = None
):

• node_id (str): The ID of the node.
• tag_name (str): The tag name of the node.
• time_label (str, optional): A specific timestamp to set for the node’s time label property. If not provided, no timestamp will be added. (default: :obj:None)

​

_extract_nodes

def _extract_nodes(self, graph_elements: List[Any]):

• graph_elements (List[Any]): A list of graph elements containing nodes.

​

_extract_relationships

def _extract_relationships(self, graph_elements: List[Any]):

• graph_elements (List[Any]): A list of graph elements containing relationships.

​

refresh_schema

def refresh_schema(self):

​

get_structured_schema

def get_structured_schema(self):

​

get_schema

def get_schema(self):

​

get_indexes

def get_indexes(self):

​

add_triplet

def add_triplet(
    self,
    subj: str,
    obj: str,
    rel: str,
    time_label: Optional[str] = None
):

• subj (str): The identifier for the subject entity.
• obj (str): The identifier for the object entity.
• rel (str): The relationship between the subject and object.
• time_label (str, optional): A specific timestamp to set for the time label property of the relationship. If not provided, no timestamp will be added. (default: :obj:None)

​

delete_triplet

def delete_triplet(
    self,
    subj: str,
    obj: str,
    rel: str
):

• subj (str): The identifier for the subject entity.
• obj (str): The identifier for the object entity.
• rel (str): The relationship between the subject and object.

​

delete_entity

def delete_entity(self, entity_id: str):

• entity_id (str): The identifier of the entity to be deleted.

​

_check_edges

def _check_edges(self, entity_id: str):

• entity_id (str): The identifier of the entity.

​

get_node_properties

def get_node_properties(self):

​

get_relationship_properties

def get_relationship_properties(self):

​

_validate_time_label

def _validate_time_label(self, time_label: str):

• time_label (str): The time label string to validate. Should be in format ‘YYYY-MM-DDThh:mm:ss’.