后台作业

限定名称 类型

apoc.periodic.list
apoc.periodic.list() - 返回所有后台作业的 LIST<ANY>。

过程

apoc.periodic.submit
apoc.periodic.submit(name STRING, statement STRING, params MAP<STRING, ANY>) - 创建一个后台作业，该作业运行给定的 Cypher 语句一次。

过程

apoc.periodic.countdown
apoc.periodic.repeat(name STRING, statement STRING, rate INTEGER, config MAP<STRING, ANY>) - 运行一个重复调用的后台作业。要停止此过程，请使用 apoc.periodic.cancel。

过程

  • 作业列表每 10 秒更新一次已完成的作业。

附加配置

许多过程在后台或异步运行。以下设置将覆盖默认线程池大小 (处理器*2)

apoc.jobs.pool.num_threads=10

许多周期性过程依赖于一个调度执行器，该执行器具有一个默认固定大小（处理器/4，至少 1 个）的线程池。要配置线程池大小，请使用以下配置属性

apoc.jobs.scheduled.num_threads=10

倒计时示例

此语句会重复执行直到达到终止条件。该语句必须返回一个数值，并且该值应递减（类似于单调递减函数）。当返回值达到 0 时，迭代停止。

例如，要定义一个具有数值属性的计数器，请使用以下命令

CREATE (counter:Counter) SET counter.c = 10

要每秒将此属性减 1，请使用以下命令

CALL apoc.periodic.countdown('decrement',"MATCH (counter:Counter) SET counter.c = counter.c - 1 RETURN counter.c as count", 1)
© . All rights reserved.