|| apoc.periodic.repeat - APOC 核心文档 - Neo4j 文档

apoc.periodic.repeat

详情
语法	`apoc.periodic.repeat(name, statement, rate [, config ]) :: (name, delay, rate, done, cancelled)`
描述	运行一个重复调用的后台任务。要停止此过程，请使用 `apoc.periodic.cancel`。
输入参数	名称	类型	描述
	`name`	`STRING`	任务的名称。
	`statement`	`STRING`	要运行的 Cypher 语句。
	`rate`	`INTEGER`	每次任务执行之间等待的延迟时间（秒）。
	`config`	`MAP`	`{ params = {} :: MAP }` 默认值为：`{}`。
返回参数	名称	类型	描述
	`name`	`STRING`	任务的名称。
	`delay`	`INTEGER`	任务的延迟。
	`rate`	`INTEGER`	任务的速率。
	`done`	`BOOLEAN`	任务是否已完成。
	`cancelled`	`BOOLEAN`	任务是否已取消。

用法示例

我们可以通过运行以下查询每秒创建 10 个 Person 节点

CALL apoc.periodic.repeat(
  "create-people",
  "UNWIND range(1,10) AS id CREATE (:Person {uuid: apoc.create.uuid()})",
   1
);

结果
name	delay	rate	done	cancelled
"create-people"	0	1	FALSE	FALSE

我们可以通过运行以下查询检查已创建了多少个节点

MATCH (:Person)
RETURN count(*) AS count;

结果
count
110

如果我们想取消此任务，可以使用 apoc.periodic.cancel 过程。