Port to latest GQLAlchemy

backend/python/requirements.txt

@@ -1,2 +1,2 @@
-kafka-python
-gqlalchemy
+kafka-python==2.0.2
+git+https://github.com/memgraph/gqlalchemy.git@add-create-stream

memgraph/README.md

@@ -10,3 +10,8 @@ creates required indexes, constraints, and triggers.
 ```bash
 bash run.sh memgraph
 ```
+
+## NOTES
+
+Memgraph transform script inside `query_modules` can NOT be called `kafka.py`
+because of a conflict with the `KAFKA` clause.

memgraph/gqlalchmey/main.py

@@ -0,0 +1,4 @@
+from gqlalchemy import Memgraph
+
+if __name__ == "__main__":
+    pass

memgraph/gqlalchmey/requirements.txt

@@ -0,0 +1 @@
+git+https://github.com/memgraph/gqlalchemy.git@add-create-stream

memgraph/queries/create_stream.cypher

@@ -1 +1 @@
-CREATE STREAM kafkaStream TOPICS topic TRANSFORM kafka.transform;
+CREATE KAFKA STREAM kafkaStream TOPICS topic TRANSFORM kafka_stream.transform;

memgraph/run.sh

@@ -11,6 +11,7 @@ script_help_and_exit () {
     echo "    action - takes a filename (excluding the extension) from the"
     echo "             queries directory. The file contains a query that will"
     echo "             be executed in the running Memgraph instance"
+    echo "    init_gqlalchemy - initializes Memgraph using GQLAlchmey"
     exit 1
 }
 
@@ -83,6 +84,10 @@ case "$action" in
         init
     ;;
 
+    init_gqlalchemy)
+        python3 gqlalchmey/main.py
+    ;;
+
     drop)
         drop
     ;;