简介
状态存储以抽象数据结构的方式为用户提供多种类型的持久化存储方式,主要有以下特点:
提供字符串(string)、列表(list)、 哈希(hash)等数据结构的存储。
支持数据的持久化,数据保持在磁盘中,流重启的时候可以再次加载进行使用。
支持的数据类型:
字符串(string):字符串,字符串与键一一对应。
列表(list):简单字符串列表,按照插入顺序排序,列表与键一一对应。
哈希(hash):字符串类型的key和value的映射表,映射表与键一一对应。
连接器配置
配置参数
参数 | 数据类型 | 描述 | 是否必填 |
键 | string | 状态的唯一标识,长度限制30字符 | 是 |
配置界面
操作说明
字符串
字符串支持的操作:设置字符串的值、获取字符串的值、删除字符串、设置字符串的过期时间。
参数配置
参数 | 数据类型 | 描述 | 是否必填 | 默认值 |
值 | string | 需要更新的值,长度限制4GB | 是 | - |
输出
执行成功时,输出结果会保存在 message 消息体的 payload;执行失败时,错误信息会保存在 message 消息体的 error。
组件输出的 message 信息如下:
message 属性 | 值 |
payload | 执行成功后,payload 为 dict 类型,包含"value"元素,"value"表示设置后的数据;执行失败后,payload 为空 |
error | 执行成功后,error 为空;执行失败后,error 为 dict 类型,包含“Code”和“Description”字段:“Code”字段表示错误类型,“Description”字段表示错误具体信息 |
attribute | 继承上个组件的 attribute 信息 |
variable | 继承上个组件的 variable 信息 |
例如:执行成功后,message payload 值如下:
{"value": "value"}
执行失败后,message error 值如下:
{"Code": "CORE:RUNTIME","Description": "Can't connect to MySQL server on '*'"}
案例
1. 添加状态存储组件,选择设置字符串的值操作。
2. 新建状态存储配置,配置键。
3. 执行操作。设置成功后,message payload 中包含设置后数据:
参数配置
仅需配置通用配置。
输出
执行成功时,输出结果会保存在 message 消息体的 payload;执行失败时,错误信息会保存在 message 消息体的 error。
组件输出的 message 信息如下:
message 属性 | 值 |
payload | 执行成功后,payload 为 dict 类型,包含"value"元素,"value"表示获取的数据;执行失败后,payload 为空 |
error | 执行成功后,error 为空;执行失败后,error 为 dict 类型,包含“Code”和“Description”字段:“Code”字段表示错误类型,“Description”字段表示错误具体信息 |
attribute | 继承上个组件的 attribute 信息 |
variable | 继承上个组件的 variable 信息 |
例如:执行成功后,message payload 值如下:
{"value": "value"}
执行失败后,message error 值如下:
{"Code": "CORE:RUNTIME","Description": "Can't connect to MySQL server on '*'"}
案例
1. 添加状态存储组件,选择获取字符串的值操作。
2. 新建状态存储配置,配置键。
3. 执行操作。获取成功后,message payload 中包含获取的数据。
参数配置
仅需配置通用配置。
输出
执行成功时,没有结果返回;执行失败时,错误信息会保存在 message 消息体的 error。
组件输出的 message 信息如下:
message 属性 | 值 |
payload | 执行成功后,payload 为空;执行失败后,payload 为空 |
error | 执行成功后,error 为空;执行失败后,error 为 dict 类型,包含“Code”和“Description”字段:“Code”字段表示错误类型,“Description”字段表示错误具体信息 |
attribute | 继承上个组件的 attribute 信息 |
variable | 继承上个组件的 variable 信息 |
执行失败后,message error 值如下:
{"Code": "CORE:RUNTIME","Description": "Can't connect to MySQL server on '*'"}
案例
1. 添加状态存储组件,选择删除字符串操作。
2. 新建状态存储配置,配置键。
3. 执行操作。删除成功后,message payload 为空。
参数配置
参数 | 数据类型 | 描述 | 是否必填 | 默认值 |
过期时间 | int | 过期时间(单位天) | 是 | - |
输出
执行成功时,无结果返回;执行失败时,错误信息会保存在 message 消息体的 error。
组件输出的 message 信息如下:
message 属性 | 值 |
payload | 执行成功后,payload 为空;执行失败后,payload 为空 |
error | 执行成功后,error 为空;执行失败后,error 为 dict 类型,包含“Code”和“Description”字段:“Code”字段表示错误类型,“Description”字段表示错误具体信息 |
attribute | 继承上个组件的 attribute 信息 |
variable | 继承上个组件的 variable 信息 |
执行失败后,message error 值如下:
{"Code": "CORE:RUNTIME","Description": "Can't connect to MySQL server on '*'"}
案例
1. 添加状态存储组件,选择设置字符串的过期时间操作。
2. 新建状态存储配置,配置键。
3. 执行操作。设置成功后,message payload 为空。
列表
列表支持的操作:插入值到列表尾部、插入值到列表头部、获取列表的尾部元素、获取列表的头部元素、移出列表尾部元素、移出列表头部元素、获取列表长度、删除列表、设置列表的过期时间。
参数配置
参数 | 数据类型 | 描述 | 是否必填 | 默认值 |
值 | string | 需要更新的值,长度限制4G | 是 | |
输出
执行成功时,输出结果会保存在 message 消息体的 payload;执行失败时,错误信息会保存在 message 消息体的 error。
组件输出的 message 信息如下:
message 属性 | 值 |
payload | 执行成功后,payload 为 dict 类型,包含"value"元素,"value"表示插入的数据;执行失败后,payload 为空 |
error | 执行成功后,error 为空;执行失败后,error 为 dict 类型,包含“Code”和“Description”字段:“Code”字段表示错误类型,“Description”字段表示错误具体信息 |
attribute | 继承上个组件的 attribute 信息 |
variable | 继承上个组件的 variable 信息 |
例如:执行成功后,message payload 值如下:
{"value": "test"}
执行失败后,message error 值如下:
{"Code": "CORE:RUNTIME","Description": "Can't connect to MySQL server on '*'"}
案例
1. 添加状态存储组件,选择插入值到列表尾部操作。
2. 新建状态存储配置,配置键。
3. 执行操作。插入成功后,message payload 中包含插入数据:
参数配置
参数 | 数据类型 | 描述 | 是否必填 | 默认值 |
值 | string | 需要更新的数据,长度限制4GB | 是 | - |
输出
执行成功时,输出结果会保存在 message 消息体的 payload;执行失败时,错误信息会保存在 message 消息体的 error。
组件输出的 message 信息如下:
message 属性 | 值 |
payload | 执行成功后,payload 为 dict 类型,包含"value"元素,"value"表示插入的数据;执行失败后,payload 为空 |
error | 执行成功后,error 为空;执行失败后,error 为 dict 类型,包含“Code”和“Description”字段:“Code”字段表示错误类型,“Description”字段表示错误具体信息 |
attribute | 继承上个组件的 attribute 信息 |
variable | 继承上个组件的 variable 信息 |
例如:执行成功后,message payload 值如下:
{"value": "test"}
执行失败后,message error 值如下:
{"Code": "CORE:RUNTIME","Description": "Can't connect to MySQL server on '*'"}
案例
1. 添加状态存储组件,选择插入值到列表头部操作。
2. 新建状态存储配置,配置键。
3. 执行操作。插入成功后,message payload 中包含插入数据:
参数配置
仅需配置通用配置。
输出
执行成功时,输出结果会保存在 message 消息体的 payload;执行失败时,错误信息会保存在 message 消息体的 error。
组件输出的 message 信息如下:
message 属性 | 值 |
payload | 执行成功后,payload 为 dict 类型,包含"value"元素,"value"表示获取的数据;执行失败后,payload 为空 |
error | 执行成功后,error 为空;执行失败后,error 为 dict 类型,包含“Code”和“Description”字段:“Code”字段表示错误类型,“Description”字段表示错误具体信息 |
attribute | 继承上个组件的 attribute 信息 |
variable | 继承上个组件的 variable 信息 |
例如:执行成功后,message payload 值如下:
{"value": "test"}
执行失败后,message error 值如下:
{"Code": "CORE:RUNTIME","Description": "Can't connect to MySQL server on '*'"}
案例
1. 添加状态存储组件,选择获取列表的尾部元素操作。
2. 新建状态存储配置,配置键。
3. 执行操作。获取成功后,message payload 中包含获取的数据:
参数配置
仅需配置通用配置。
输出
执行成功时,输出结果会保存在 message 消息体的 payload;执行失败时,错误信息会保存在 message 消息体的 error。
组件输出的 message 信息如下:
message 属性 | 值 |
payload | 执行成功后,payload 为 dict 类型,包含"value"元素,"value"表示获取的数据;执行失败后,payload 为空 |
error | 执行成功后,error 为空;执行失败后,error 为 dict 类型,包含“Code”和“Description”字段:“Code”字段表示错误类型,“Description”字段表示错误具体信息 |
attribute | 继承上个组件的 attribute 信息 |
variable | 继承上个组件的 variable 信息 |
例如:执行成功后,message payload 值如下:
{"value": "test"}
执行失败后,message error 值如下:
{"Code": "CORE:RUNTIME","Description": "Can't connect to MySQL server on '*'"}
案例
1. 添加状态存储组件,选择获取列表的头部元素操作。
2. 新建状态存储配置,配置键。
3. 执行操作。获取成功后,message payload 中包含获取的数据:
参数配置
仅需配置通用配置。
输出
执行成功时,输出结果会保存在 message 消息体的 payload;执行失败时,错误信息会保存在 message 消息体的 error。
组件输出的 message 信息如下:
message 属性 | 值 |
payload | 执行成功后,payload 为 dict 类型,包含"value"元素,"value"表示被移出的数据;执行失败后,payload 为空 |
error | 执行成功后,error 为空;执行失败后,error 为 dict 类型,包含“Code”和“Description”字段:“Code”字段表示错误类型,“Description”字段表示错误具体信息 |
attribute | 继承上个组件的 attribute 信息 |
variable | 继承上个组件的 variable 信息 |
例如:执行成功后,message payload 值如下:
{"value": "test"}
执行失败后,message error 值如下:
{"Code": "CORE:RUNTIME","Description": "Can't connect to MySQL server on '*'"}
案例
1. 添加状态存储组件,选择移出列表尾部元素操作。
2. 新建状态存储配置,配置键。
3. 执行操作。移出成功后,message payload 中包含被移出的数据:
参数配置
仅需配置通用配置。
输出
执行成功时,输出结果会保存在 message 消息体的 payload;执行失败时,错误信息会保存在 message 消息体的 error。
组件输出的 message 信息如下:
message 属性 | 值 |
payload | 执行成功后,payload 为 dict 类型,包含"value"元素,"value"表示移出的数据;执行失败后,payload 为空 |
error | 执行成功后,error 为空;执行失败后,error 为 dict 类型,包含“Code”和“Description”字段:“Code”字段表示错误类型,“Description”字段表示错误具体信息 |
attribute | 继承上个组件的 attribute 信息 |
variable | 继承上个组件的 variable 信息 |
例如:执行成功后,message payload 值如下:
{"value": "test"}
执行失败后,message error 值如下:
{"Code": "CORE:RUNTIME","Description": "Can't connect to MySQL server on '*'"}
案例
1. 添加状态存储组件,选择移出列表头部元素操作。
2. 新建状态存储配置,配置键。
3. 执行操作。移出成功后,message payload 中包含被移出的数据:
参数配置
仅需配置通用配置。
输出
执行成功时,输出结果会保存在 message 消息体的 payload;执行失败时,错误信息会保存在 message 消息体的 error。
组件输出的 message 信息如下:
message 属性 | 值 |
payload | 执行成功后,payload 为 dict 类型,包含"size"元素,"size"表示获取的长度;执行失败后,payload 为空 |
error | 执行成功后,error 为空;执行失败后,error 为 dict 类型,包含“Code”和“Description”字段:“Code”字段表示错误类型,“Description”字段表示错误具体信息 |
attribute | 继承上个组件的 attribute 信息 |
variable | 继承上个组件的 variable 信息 |
例如:执行成功后,message payload 值如下:
{"size": 1}
执行失败后,message error 值如下:
{"Code": "CORE:RUNTIME","Description": "Can't connect to MySQL server on '*'"}
案例
1. 添加状态存储组件,选择获取列表长度操作。
2. 新建状态存储配置,配置键。
3. 执行操作。获取成功后,message payload 中包含获取的长度:
参数配置
仅需配置通用配置。
输出
执行成功时,无结果返回;执行失败时,错误信息会保存在 message 消息体的 error。
组件输出的 message 信息如下:
message 属性 | 值 |
payload | 执行成功后,payload 为空;执行失败后,payload 为空 |
error | 执行成功后,error 为空;执行失败后,error 为 dict 类型,包含“Code”和“Description”字段:“Code”字段表示错误类型,“Description”字段表示错误具体信息 |
attribute | 继承上个组件的 attribute 信息 |
variable | 继承上个组件的 variable 信息 |
执行失败后,message error 值如下:
{"Code": "CORE:RUNTIME","Description": "Can't connect to MySQL server on '*'"}
案例
1. 添加状态存储组件,选择删除列表操作。
2. 新建状态存储配置,配置键。
3. 执行操作。删除成功后,message payload 为空。
参数配置
参数 | 数据类型 | 描述 | 是否必填 | 默认值 |
过期时间 | int | 过期时间(单位天) | 是 | - |
输出
执行成功时,无结果返回;执行失败时,错误信息会保存在 message 消息体的 error。
组件输出的 message 信息如下:
message 属性 | 值 |
payload | 执行成功后,payload 为空;执行失败后,payload 为空 |
error | 执行成功后,error 为空;执行失败后,error 为 dict 类型,包含“Code”和“Description”字段:“Code”字段表示错误类型,“Description”字段表示错误具体信息 |
attribute | 继承上个组件的 attribute 信息 |
variable | 继承上个组件的 variable 信息 |
执行失败后,message error 值如下:
{"Code": "CORE:RUNTIME","Description": "Can't connect to MySQL server on '*'"}
案例
1. 添加状态存储组件,选择设置列表的过期时间操作。
2. 新建状态存储配置,配置键。
3. 执行操作。设置成功后,message payload 为空。
哈希
哈希支持的操作:设置哈希表中指定字段的值、获取哈希表中指定字段的值、删除哈希表中指定字段、检查哈希表中指定字段是否存在、获取哈希表中字段的数量、删除哈希表、设置哈希表的过期时间。
如果字段存在,则会将字段对应的值更新为新值。
参数配置
参数 | 数据类型 | 描述 | 是否必填 | 默认值 |
字段 | string | 需要更新的字段,长度限制512字符 | 是 | - |
值 | string | 需要更新的值,长度限制4GB | 是 | - |
输出
执行成功时,输出结果会保存在 message 消息体的 payload;执行失败时,错误信息会保存在 message 消息体的 error。
组件输出的 message 信息如下:
message 属性 | 值 |
payload | 执行成功后,payload 为 dict 类型,包含"key"和"value"元素,"key"表示设置的字段,"value"表示设置的值;执行失败后,payload 为空 |
error | 执行成功后,error 为空;执行失败后,error 为 dict 类型,包含“Code”和“Description”字段:“Code”字段表示错误类型,“Description”字段表示错误具体信息 |
attribute | 继承上个组件的 attribute 信息 |
variable | 继承上个组件的 variable 信息 |
例如:执行成功后,message payload 值如下:
{"key": "key","value": "test"}
执行失败后,message error 值如下:
{"Code": "CORE:RUNTIME","Description": "Can't connect to MySQL server on '*'"}
案例
1. 添加状态存储组件,选择设置哈希表中指定字段的值操作。
2. 新建状态存储配置,配置键。
3. 执行操作。设置成功后,message payload 中包含设置后的数据:
参数配置
参数 | 数据类型 | 描述 | 是否必填 | 默认值 |
字段 | string | 需要获取的字段,长度限制512个字符 | 是 | |
输出
执行成功时,输出结果会保存在 message 消息体的 payload;执行失败时,错误信息会保存在 Message 消息体的 error。
组件输出的 message 信息如下:
message 属性 | 值 |
payload | 执行成功后,payload 为 dict 类型,包含"key"和"value"元素,"key"表示获取的字段,"value"表示获取的值;执行失败后,payload 为空 |
error | 执行成功后,error 为空;执行失败后,error 为 dict 类型,包含“Code”和“Description”字段:“Code”字段表示错误类型,“Description”字段表示错误具体信息 |
attribute | 继承上个组件的 attribute 信息 |
variable | 继承上个组件的 variable 信息 |
例如:执行成功后,message payload 值如下:
{"key": "key","value": "test"}
执行失败后,message error 值如下:
{"Code": "CORE:RUNTIME","Description": "Can't connect to MySQL server on '*'"}
案例
1. 添加状态存储组件,选择获取哈希表中指定字段的值操作。
2. 新建状态存储配置,配置键。
3. 执行操作。获取成功后,message 的 payload 中包含获取的数据:
参数配置
参数 | 数据类型 | 描述 | 是否必填 | 默认值 |
字段 | string | 需要删除字段,长度限制512个字符 | 是 | - |
输出
执行成功时,输出结果会保存在 message 消息体的 payload;执行失败时,错误信息会保存在 message 消息体的 error。
组件输出的 message 信息如下:
message 属性 | 值 |
payload | 执行成功后,payload 为 dict 类型,包含"key"和"value"元素,"key"表示被删除的字段,"value"表示删除的结果;执行失败后,payload 为空 |
error | 执行成功后,error 为空;执行失败后,error 为 dict 类型,包含“Code”和“Description”字段:“Code”字段表示错误类型,“Description”字段表示错误具体信息 |
attribute | 继承上个组件的 attribute 信息 |
variable | 继承上个组件的 variable 信息 |
例如:执行成功后,message payload 值如下:
{"key": "key","value": true}
执行失败后,message error 值如下:
{"Code": "CORE:RUNTIME","Description": "Can't connect to MySQL server on '*'"}
案例
1. 添加状态存储组件,选择删除哈希表中指定字段操作。
2. 新建状态存储配置,配置键。
3. 执行操作。删除成功后,message payload 中包含删除的数据:
参数配置
参数 | 数据类型 | 描述 | 是否必填 | 默认值 |
字段 | string | 需要检查的字段,长度限制512字符 | 是 | - |
输出
执行成功时,输出结果会保存在 message 消息体的 payload;执行失败时,错误信息会保存在 message 消息体的 error。
组件输出的 message 信息如下:
message 属性 | 值 |
payload | 执行成功后,payload 为 dict 类型,包含"key"和"value"元素,"key"表示获取的字段,"value"表示检查的结果;执行失败后,payload 为空 |
error | 执行成功后,error 为空;执行失败后,error 为 dict 类型,包含“Code”和“Description”字段:“Code”字段表示错误类型,“Description”字段表示错误具体信息 |
attribute | 继承上个组件的 attribute 信息 |
variable | 继承上个组件的 variable 信息 |
例如:执行成功后,message payload 值如下:
{"key": "key","value": true}
执行失败后,message error 值如下:
{"Code": "CORE:RUNTIME","Description": "Can't connect to MySQL server on '*'"}
案例
1. 添加状态存储组件,选择检查哈希表中指定字段是否存在操作。
2. 新建状态存储配置,配置键。
3. 执行操作。检查成功后,message payload 中包含检查的结果:
参数配置
仅需配置通用配置。
输出
执行成功时,输出结果会保存在 message 消息体的 payload;执行失败时,错误信息会保存在 message 消息体的 error。
组件输出的 message 信息如下:
message 属性 | 值 |
payload | 执行成功后,payload 为 dict 类型,包含"size"元素,"size"表示获取的数量;执行失败后,payload 为空 |
error | 执行成功后,error 为空;执行失败后,error 为 dict 类型,包含“Code”和“Description”字段:“Code”字段表示错误类型,“Description”字段表示错误具体信息 |
attribute | 继承上个组件的 attribute 信息 |
variable | 继承上个组件的 variable 信息 |
例如:执行成功后,message payload 值如下:
{"size": 1}
执行失败后,message error 值如下:
{"Code": "CORE:RUNTIME","Description": "Can't connect to MySQL server on '*'"}
案例
1. 添加状态存储组件,选择获取哈希表中字段的数量操作。
2. 新建状态存储配置,配置键。
3. 执行操作。获取成功后,message payload 中包含哈希表中字段的数量:
参数配置
仅需配置通用配置。
输出
执行成功时,无结果返回;执行失败时,错误信息会保存在 message 消息体的 error。
组件输出的 message 信息如下:
message 属性 | 值 |
payload | 执行成功后,payload 为空;执行失败后,payload 为空 |
error | 执行成功后,error 为空;执行失败后,error 为 dict 类型,包含“Code”和“Description”字段:“Code”字段表示错误类型,“Description”字段表示错误具体信息 |
attribute | 继承上个组件的 attribute 信息 |
variable | 继承上个组件的 variable 信息 |
执行失败后,message error 值如下:
{"Code": "CORE:RUNTIME","Description": "Can't connect to MySQL server on '*'"}
案例
1. 添加状态存储组件,选择删除哈希表操作。
2. 新建状态存储配置,配置键。
3. 执行操作。获取成功后,message payload 中为空。
参数配置
参数 | 数据类型 | 描述 | 是否必填 | 默认值 |
过期时间 | int | 过期时间(单位天) | 是 | - |
输出
执行成功时,没有结果返回;执行失败时,错误信息会保存在 message 消息体的 error。
组件输出的 message 信息如下:
message 属性 | 值 |
payload | 执行成功后,payload 为空;执行失败后,payload 为空 |
error | 执行成功后,error 为空;执行失败后,error 为 dict 类型,包含“Code”和“Description”字段:“Code”字段表示错误类型,“Description”字段表示错误具体信息 |
attribute | 继承上个组件的 attribute 信息 |
variable | 继承上个组件的 variable 信息 |
执行失败后,message error 值如下:
{"Code": "CORE:RUNTIME","Description": "Can't connect to MySQL server on '*'"}
案例
1. 添加状态存储组件,选择设置哈希表的过期时间操作。
2. 新建状态存储配置,配置键。
3. 执行操作。设置成功后,message payload 中为空。