如何从 Python 创建 Pulsar 流？答案

【问题标题】：How can I create Pulsar stream from Python?如何从 Python 创建 Pulsar 流？
【发布时间】：2022-10-24 20:00:14
【问题描述】：

如何直接从 Python 创建 Kafka 流？我知道我需要使用GQLAlchemy，但我不知道确切的命令。

【问题讨论】：

标签： memgraphdb

【解决方案1】：

GQLAlchemy 是一个完全开源的 Python 库和对象图映射器 (OGM)——图数据库对象和 Python 对象之间的链接。

对象图映射器或 OGM 提供了一个对开发人员友好的工作流程，允许编写面向对象的符号以与图数据库进行通信。这意味着您可以编写面向对象的代码，而不是编写 Cypher 查询，OGM 将自动将其转换为 Cypher 查询。

您可以使用以下代码连接到 Pulsar 流：

from gqlalchemy import MemgraphPulsarStream
stream = MemgraphPulsarStream(name="ratings_stream", topics=["ratings"], transform="movielens.rating", service_url="localhost:6650")
db.create_stream(stream)
db.start_stream(stream)

【讨论】：