关于Memgraph持久化、Cypher读写及实时特性的技术问询

1. 是否支持通过Cypher创建/修改节点？ #

完全支持，Memgraph对Cypher语法的覆盖度很高，创建、修改节点都是基础核心操作，举两个实用示例：

• 创建带标签和属性的节点：

  CREATE (p:Person {name: "Bob", email: "bob@example.com"})
  

• 修改已有节点的属性：

  MATCH (p:Person {name: "Bob"})
  SET p.email = "bob_new@example.com", p.age = 28
  

除节点外，关系的创建、修改也能用标准Cypher语法实现。

2. Memgraph是否为持久化存储？ #

Memgraph是内存优先的图数据库，但完全支持数据持久化，核心依赖两种机制：

• 预写日志（WAL）：默认开启，所有数据变更都会先写入日志文件，即使服务意外重启，也能通过日志恢复数据，保证数据不丢失。
• 快照（Snapshot）：定期把当前图数据完整保存到磁盘文件，默认每小时生成一次快照，也可以手动触发或调整生成间隔。
  你可以通过配置文件调整持久化相关参数，比如快照频率、日志保留时间等。

3. 官网强调的实时特性具体含义？ #

Memgraph的实时特性主要针对流数据处理与实时图查询场景：

• 它能在持续摄入流数据（比如Kafka、Pulsar的消息）的同时，立即对最新的图数据运行Cypher查询，延迟低至毫秒级。
• 不同于传统批处理数据库需要等数据批量导入完成才能查询，Memgraph适合需要实时响应的场景：比如实时网络安全监控、电商实时推荐、实时社交关系分析等，能基于最新的图状态快速返回结果。

4. Kafka直连存储功能是什么？ #

这个功能让Memgraph可以直接对接Kafka集群，无需额外中间件就能摄入流数据：

• 你可以用Cypher语句定义Kafka流，指定要消费的主题、数据格式（JSON、Avro等），再编写映射逻辑，把Kafka消息里的字段直接转换成图的节点、关系或属性。
• 简单流处理示例：

  -- 创建Kafka流
  CREATE STREAM user_stream 
  TOPICS 'user-signups' 
  FORMAT JSON 
  BOOTSTRAP_SERVERS 'kafka:9092';
  
  -- 定义消息到图的映射
  CREATE QUERY MAPPING user_mapping
  FOR STREAM user_stream
  AS MATCH (c:Country {code: event.country_code})
  MERGE (u:User {id: event.user_id})
  SET u.name = event.user_name
  MERGE (u)-[:RESIDES_IN]->(c);
  

Kafka里的新消息一产生，就会实时同步到Memgraph的图中，非常适合构建实时更新的图数据模型。

内容的提问来源于stack exchange，提问作者MPesi