跳转到内容

RedisGears命令复述,客户

下面几节描述支持的命令。

命令 描述
RG。ABORTEXECUTION 中止执行
RG.CONFIGGET 返回配置键
RG。CONFIGSET 设置配置密钥
RG。DROPEXECUTION 删除执行
RG。DUMPEXECUTIONS 输出执行
RG。DUMPREGISTRATIONS 输出注册
RG.GETEXECUTION 返回执行的详细信息
RG.GETRESULTS 返回执行的结果
RG.GETRESULTSBLOCKING 阻塞客户端直到执行结束
RG。INFOCLUSTER 返回集群信息
RG。PYEXECUTE 执行Python函数并注册用于事件驱动处理的函数
RG。PYSTATS 返回内存使用统计信息
RG。REFRESHCLUSTER 刷新节点在集群中的视图
RG.PYDUMPREQS 返回关于需求的详细信息
RG。REFRESHCLUSTER 刷新节点的集群视图
> > > > > > >的主人
RG。触发 触发注册的执行
注销 删除注册

语法规则

我们使用以下约定来描述Redis API:

  • 命令:命令
  • <强制性>:强制参数
  • [可选]:可选参数
  • :字面量的双引号字符
  • |排他性的或
  • ...:和以前一样多

RG。ABORTEXECUTION执行飞行途中的一个函数。

RedisAPI

RG.ABORTEXECUTION

论据

返回

如果成功,则为简单的“OK”,如果执行不存在或已完成,则为错误。

例子

redis>RG.ABORTEXECUTION 0000000000000000000000000000000000-1正常

RG.CONFIGGET配置或用户定义的选项。

RedisAPI

RG.CONFIGGET[…]

论据

  • 关键:要获取的配置选项

返回

每个键都有一个条目的数组。该条目是一个字符串,是未定义选项的值或错误。

例子

复述> RG。CONFIGGET ProfileExecutions 1) (integer) 0 redis> RG. execute 1)CONFIGGET foo (1)(error) (error) Unsupported config parameter: foo

RG。CONFIGSET配置或用户定义的选项。

RedisAPI

RG。CONFIGSET  […]

论据

  • 关键:要设置的配置选项
  • 价值:新值

返回

每个键都有一个条目的数组。该条目是简单的'OK'字符串,如果该选项不能在运行时配置,则会出现错误。

例子

复述> RG。CONFIGSETProfileExecutions1 1) OK redis> RG.CONFIGSET foo bar 1) OK - value was saved in extra config dictionary redis> RG.CONFIGGET foo 1) "bar"

RG。DROPEXECUTION执行从执行列表中选择一个函数。

RedisAPI

RG。DROPEXECUTION < id >

论据

返回

如果成功,则为简单的“OK”,如果执行不存在或仍在运行,则为错误。

例子

redis>RG.DROPEXECUTION 0000000000000000000000000000-1正常

RG。DUMPEXECUTIONS函数执行.执行列表的长度由最大执行配置选项。

RedisAPI

RG。DUMPEXECUTIONS

返回

每次执行都有一个条目的数组。每个条目由下列键名和值条目交替组成:

例子

redis>RG.DUMPEXECUTIONS 1)1)“executionId”2)“0000000000000000000000000000000000000000-0”3)“状态”4)“完成”5)“注册执行”6)(整数)12)1)“executionId”2)“0000000000000000000000000000000000000000-1”3)“状态”4)“运行”5)“注册执行”6)(整数)1

RG。DUMPREGISTRATIONS函数注册

RedisAPI

RG。DUMPREGISTRATIONS

返回

每个注册都有一个条目的数组。每个条目由下列键名和值条目交替组成:

  • 身份证件:登记身份证
  • 读者:读者
  • desc:描述
  • 注册数据:一个由以下元素组成的数组:
    • 模式:注册模式
    • numTriggered:触发执行的计数器
    • numSuccess:成功执行的计数器
    • numFailures:执行失败的计数器
    • numAborted:中止执行的计数器
    • 最后错误:最后一个返回的错误
    • args: reader-specific参数
  • PD:私人数据

例子

redis>RG.DUMPREGISTRATIONS 1)1)“id”2)“0000000000000000000000000000000000-2”3)“读卡器”4)“键读卡器”5)“描述”6)(零)7)“注册数据”8)1)“模式”2)“异步”3)“numTriggered”4)(整数)0 5)“numSuccess”6)(整数)0 7)“numFailures”8)(整数)0 9)“numborted”10)(整数)0 11)“lastError”12)(零)13)参数“14)1)“regex”2“*”3)“eventTypes”4)(nil)5)“keyTypes”6)(nil)9)“PD”10“{'sessionId':'00000000000000000000000000000000000-3”,“depsList':[]}”

RG.GETEXECUTION执行执行列表中的函数的详细信息。

RedisAPI

RG.GETEXECUTION [SHARD|CLUSTER]

论据

  • 身份证件:执行ID得到
  • 碎片:仅获取本地执行(中的默认值独立的模式)
  • :从碎片收集所有执行(默认为集群模式)

再发现琐事

当与参数,RedisGears运行一个RedisGears函数,该函数收集碎片的执行计划…自引用非常矛盾:)

返回

如果执行成功则返回数组,如果执行不存在或仍在运行则返回错误。该数组由以下交替的键名和值条目组成:

  • shard_id:群集中碎片的标识符
  • 执行计划:执行计划由:
    • 地位:地位
    • 收到碎片:接收执行的碎片数
    • shards_completed:完成执行的碎片数
    • 结果:返回的结果计数
    • 错误:产生的错误计数
    • total_duration:总执行持续时间(毫秒)
    • 读取持续时间:读取器执行时间,单位为毫秒
    • 台阶:该计划的步骤如下:
      • 类型:一步类型
      • 持续时间:以毫秒为单位的步长(0当ProfileExecutions禁用)
      • 的名字:一步回调
      • 参数:一步论证

例子

redis>RG.PYEXECUTE“GB().run()”解除阻止“0000000000000000000000000000000000000000000000-4”redis>RG.GETEXECUTION 0000000000000000000000000000000000000000000000000000000000-4 1)1)“碎片id”2)“0000000000000000000000000000000000000000000000”3)“执行计划”4)“状态”2)“完成”3)“碎片接收”4)(整数)0 5)“碎片完成”6)(整数)0 7)“结果”8)(整数)0 9)“错误”10)(空列表或集合)11)“总持续时间”12)(整数)0 13)“读取持续时间”14)(整数)0 15)“步骤”16)1)1)“类型”2)“收集”3)“持续时间”4)(整数)0 5)“名称”6)“收集”7)“参数”8)“类型”2)“映射”3)“持续时间”4)(整数)0 5)“名称”6)“RedigagerspyCallbackMapper”7)“参数”8)“at 0x7f8b8f869880>”3)1)“键入“2”映射“3”持续时间“4”(整数)0 5)“名称”6)“重新绑定代理”

RG.GETRESULTS结果以及执行过程中的错误执行执行列表中的函数的详细信息。

RedisAPI

RG.GETRESULTS

论据

返回

如果执行成功则返回数组,如果执行不存在或仍在运行则返回错误。应答数组由两个子数组组成:一个用于结果,另一个用于错误。

例子

复述> RG。1)(空列表或集)2)(空列表或集)

RG.GETRESULTSBLOCKINGRG。PYEXECUTE调用客户端将被阻止,直到执行结束,然后发送所有结果和错误。

RedisAPI

RG.GETRESULTSBLOCKING

论据

返回

如果执行成功,则返回一个数组;如果执行不存在,则返回一个错误。应答数组由两个子数组组成:一个用于结果,另一个用于错误。

例子

复述> RG。1)(空列表或集)2)(空列表或集)

RG。INFOCLUSTER
RG。INFOCLUSTER

返回

由下列键名和值项交替组成的数组:

  • MyId:群集中碎片的标识符
  • 一个数组,每个集群的碎片都有一个条目,如下所示:
    • 身份证件:群集中碎片的标识符
    • 知识产权:碎片的IP地址
    • 港口:碎片的端口
    • unixSocket:碎片的UDS
    • runid:发动机的运行标识符
    • minHslot:分片服务的最低哈希槽
    • maxHslot:分片服务的最高哈希槽

例子

127.0.0.1:30001 > RG。INFOCLUSTER 1)“MyId”2)"15f41d945e9e76175dd92bbfde27ded6bcfe53df" 3) 1) 1)“id”2)“十五f41d945e9e76175dd92bbfde27ded6bcfe53df”3)“知识产权”4)“127.0.0.1”5)"port" 6)(整数)30001 7)“unixSocket”8)“没有”9) "runid" 10) "a07592a2e979d8c7d028061fd7c6468463aaf79e" 11) "minHslot" 12) (integer) 0 13) "maxHslot" 14) (integer) 5460 2) 1) "id" 2) "b57e92c693e285b91b3f9cbccb9e8ae71b54516d" 3) "ip" 4) "127.0.0.1" 5) "port" 6) (integer) 30003 7) "unixSocket" 8) "None" 9) "runid" 10) "0dedafb5825f51eb1c692b4046abaa1c3c529037" 11) "minHslot" 12) (integer) 10923 13) "maxHslot" 14) (integer) 16383 3) 1) "id" 2) "0525c8651300850b73789f721912bf1eb236b51e" 3) "ip" 4) "127.0.0.1" 5) "port" 6) (integer) 30002 7) "unixSocket" 8) "None" 9) "runid" 10) "4a2bc1c3d269dbb1f007ee85da53d60e77b9ac35" 11) "minHslot" 12) (integer) 5461 13) "maxHslot" 14) (integer) 10922

RG。PYEXECUTE作用

RedisAPI

RG。PYEXECUTE "" [UNBLOCKING] [REQUIREMENTS "…"]

论据

  • 作用: Python函数
  • 疏通:在执行过程中不会阻塞客户端
  • 要求:此参数确保在执行前将作为参数给出的依赖项列表安装在每个shard上

返回

如果无法解析函数以及由使用的非RedisGears函数生成的任何函数,则返回错误。

当用于疏通模式回复是执行ID

函数生成的任何结果和错误都将作为由两个子数组组成的数组返回:一个子数组用于结果,另一个子数组用于错误。

如果函数没有输出,则返回一个简单的'OK'字符串(即它不包含任何带有运行行动)。

例子

复述> RG。PYEXECUTE"GB().run()" 1) (empty list or set) 2) (empty list or set)

RG。PYSTATSPython解释器

RedisAPI

RG。PYSTATS

返回

由下列键名和值项交替组成的数组:

  • TotalAllocated:一段时间内所有分配的字节总数
  • PeakAllocated:拨款的峰值
  • 货币分配:当前分配的内存字节数

例子

redis>RG.PYSTATS 1)“TotalAllocated”2)(整数)113803317 3)“PeakAllocated”4)(整数)8432603 5)“CurrAllocated”6)(整数)5745816

RG.PYDUMPREQS
RG.PYDUMPREQS

返回

由下列键名和值项交替组成的数组:

例子

127.0.0.1:6379>RG.PYDUMPREQS 1)1)“GearReqVersion”2)(integer)1 3)“Name”4)“redis”5)“Isdownload”6)“yes”7)“IsInstalled”8)“yes”9)“whl”10)1)“redis-3.5.2-py2.py3无任何。whl”

RG。REFRESHCLUSTER

开源Redis集群

RG。REFRESHCLUSTER命令需要在集群的每个节点上执行。

RedisAPI

RG。REFRESHCLUSTER

返回

一个简单的“OK”字符串。

例子

复述> RG。REFRESHCLUSTER好

RG。触发命令阅读器函数。

RedisAPI

RG.TRIGGER[arg…]

论据

返回

包含函数输出记录的数组。

例子

复述> RG。PYEXECUTE"GB('CommandReader').register(trigger='mytrigger')" OK redis> RG.TRIGGER mytrigger foo bar 1) "['mytrigger', 'foo', 'bar']"

注销登记的一个函数。

RedisAPI

注销

论据

返回

一个简单的'OK'字符串,或一个错误。如果注册ID不存在,或者函数的读取器不支持取消注册操作,则返回错误。

Baidu