Complete the airflow survey & get a free airflow 3 certification!

Apache TinkerPop Operators

GremlinOperator

Executes Gremlin queries on a remote Gremlin Server.

For parameter definition take a look at GremlinOperator.

Using the operator

An example usage of the GremlinOperator to query from gremlin server is as follows:

tests/system/apache/tinkerpop/example_gremlin_dag.py[source]


gremlin_task = GremlinOperator(
    task_id="run_gremlin_query", gremlin_conn_id="gremlin_conn_id", query="g.V()"
)

Reference

For further information, look at: https://tinkerpop.apache.org/gremlin.html

Was this entry helpful?