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
论据
- 身份证件:执行ID中止
返回
如果成功,则为简单的“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 >
论据
- 身份证件:执行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
论据
- 身份证件:执行ID得到
返回
如果执行成功则返回数组,如果执行不存在或仍在运行则返回错误。应答数组由两个子数组组成:一个用于结果,另一个用于错误。
例子
复述> RG。1)(空列表或集)2)(空列表或集)
RG.GETRESULTSBLOCKINGRG。PYEXECUTE
调用客户端将被阻止,直到执行结束,然后发送所有结果和错误。
RedisAPI
RG.GETRESULTSBLOCKING
论据
- 身份证件:执行ID阻碍
返回
如果执行成功,则返回一个数组;如果执行不存在,则返回一个错误。应答数组由两个子数组组成:一个用于结果,另一个用于错误。
例子
复述> RG。1)(空列表或集)2)(空列表或集)
RG。INFOCLUSTER
RG。INFOCLUSTER
RG。INFOCLUSTER