StreamReader 系列
读取 Redis 流数据。
| Redis 堆栈 |
|---|
读取 Redis 流数据。
参数
| 名字 | 类型 | 默认值 | 描述 |
|---|---|---|---|
| 批量大小 | 整数 | 1 | 将导致函数运行的新消息数 |
| 期间 | 整数 | 0 | 执行前要等待多少秒，与批处理大小无关 |
| failurePolicy | FailurePolicy （失败策略） | FailurePolicy.CONTINUE | 如何处理执行失败 （CONTINUE/ABORT/RETRY） |
| failureRetryInterval | 整数 | 5000 | 重试前等待的秒数 |
| 模式 | 字符串 | “*” （匹配所有键） | 存储流的键的模式 |
| startId （起始 ID） | 字符串 | "0-0" | 从此流 ID 开始读取 |
| trimStream （三流） | 布尔 | 真 | 是否修剪流 |
输出记录
为输入流中的每条消息创建一条记录。
每条记录都是一个HashMap<String, Object>具有以下字段：
| 名字 | 类型 | 描述 |
|---|---|---|
| 身份证 | 字符串 | 消息的 ID |
| 钥匙 | 字符串 | 流密钥名称 |
| 价值 | HashMap<String， byte[]> | 消息的数据 |
例子
以下示例创建一个StreamReader使用默认值：
StreamReader reader = new StreamReader();
To change the parameter values for a StreamReader, use their setter methods:
StreamReader reader = new StreamReader();
// Get streams for keys that match "weather"
reader.setPattern("weather");
// Run RedisGears functions after every 10 messages
reader.setBatchSize(10);
On this page