Exceptions¶
- mogwai.connection.execute_query(*args, **kwargs)¶
Execute a raw Gremlin query with the given parameters passed in.
Parameters: - query (str) – The Gremlin query to be executed
- params (dict) – Parameters to the Gremlin query
- connection (RexPro(Sync|Gevent|Eventlet)Connection or None) – The RexPro connection to execute the query with
- context – String context data to include with the query for stats logging
Return type: dict
- mogwai.connection.generate_spec()¶
Generates a titan index and type specification document based on loaded Vertex and Edge models
- mogwai.connection.get_response(query, params, isolate, transaction, connection, connection_pool)¶
- mogwai.connection.pop_execute_query_kwargs(keyword_arguments)¶
pop the optional execute query arguments from arbitrary kwargs; return non-None query kwargs in a dict
- mogwai.connection.setup(host, graph_name=u'graph', graph_obj_name=u'g', username=u'', password=u'', metric_reporters=None, pool_size=10, concurrency=u'sync')¶
Sets up the connection, and instantiates the models
- mogwai.connection.sync_spec(filename, host, graph_name=u'graph', graph_obj_name=u'g', username=u'', password=u'', dry_run=False)¶
Sync the given spec file to mogwai.
Parameters: - filename (str) – The filename of the spec file
- host (str) – The host the be synced
- graph_name (str) – The name of the graph to be synced
- dry_run (boolean) – Only prints generated Gremlin if True
Returns: None