如何将转换模块移动到Docker中运行的Memgraph？

Question

我正试图弄清楚Kafka的流媒体如何与Memgraph结合使用。我有一个运行在Docker容器中的Memgraph。我使用Visual Studio代码创建了一个名为< code>music.py的模块，但我无法将其保存到docker中。

import mgp
import json

@mgp.transformation
def rating(messages: mgp.Messages
                ) -> mgp.Record(query=str, parameters=mgp.Nullable[mgp.Map]):
    result_queries = []

    for i in range(messages.total_messages()):
        message = messages.message_at(i)
        movie_dict = json.loads(message.payload().decode('utf8'))
        result_queries.append(
            mgp.Record(
                query=("MERGE (u:User {id: $userId}) "
                        "MERGE (m:Album {id: $albumId, title: $title}) "
                        "WITH u, m "
                        "UNWIND $genres as genre "
                        "MERGE (m)-[:OF_GENRE]->(:Genre {name: genre}) "
                        "MERGE (u)-[r:RATED {rating: ToFloat($rating), timestamp: $timestamp}]->(m)"),
                parameters={
                    "userId": album_dict["userId"],
                    "albumId": album_dict["movie"]["movieId"],
                    "title": album_dict["album"]["title"],
                    "genres": album_dict["album"]["genres"],
                    "rating": album_dict["rating"],
                    "timestamp": album_dict["timestamp"]}))

    return result_queries

我应该在docker中运行< code>vi并将代码复制/粘贴到其中，还是有其他方法？

Answer 1

您需要复制音乐。py文件到Docker容器。具体步骤如下：

1. 打开命令提示符/终端，找出记忆工码头程序容器的容器ID
2. 转到保存 music.py 的文件夹/目录，然后编写以下命令：docker cp ./music.py

不要忘记替换< code >

如果您将文件安装在容器中，您也可以使用vi创建文件。我从未尝试过这样做，但请查看此问题以获取有关如何执行此操作的说明。

对我个人来说，创建转换模块最简单的方法是使用Memgraph Lab，但你没有提到你是否有它。