时间戳

首页 > 解决方案 > NiFi - 在 Groovy 脚本中调用 Redis 命令

redis - NiFi - 在 Groovy 脚本中调用 Redis 命令

问题描述

我正在尝试Redis从 groovy 脚本 ( ExecuteGroovyScript) 连接到我的实例并执行任意命令，例如LPUSH. 我目前已经RedisConnectionPoolService启用缓存处理器并且工作正常。

有什么办法可以做到这一点？任何例子都值得赞赏。

编辑：

我到了可以调用命令的地步，但由于某种原因它失败了，这是代码和错误

在此处输入图像描述

service = context.getControllerServiceLookup().getControllerService("2b841623-35ed-1e1a-0a77-46087267939d")
service.getConnection().withCloseable { redis ->
   redis.listCommands().lPush("key".getBytes(), "1".getBytes())
}

在此处输入图像描述

标签： redisapache-nifi

解决方案

如果你有call 和 call ，你RedisConnectionPoolService将有一个 Spring Redis实例，所以你可以检查他们的 API 以了解你可以进行的调用类型。serviceservice.getConnection()RedisConnection

具体来说LPUSH，您可以致电service.getConnection().listCommands().lpush()

推荐阅读