StreamReader
读取 Redis 流数据。
读取 Redis 流数据。
参数
| 名称 | 类型 | 默认值 | 描述 |
|---|---|---|---|
| batchSize | 整数 | 1 | 触发函数运行的新消息数量 |
| duration | 整数 | 0 | 执行前等待的秒数，与批次大小无关 |
| failurePolicy | FailurePolicy | FailurePolicy.CONTINUE | 如何处理执行失败（CONTINUE/ABORT/RETRY） |
| failureRetryInterval | 整数 | 5000 | 重试前等待的秒数 |
| pattern | 字符串 | "*" (匹配所有键) | 存储流的键的模式 |
| startId | 字符串 | "0-0" | 从此流 ID 开始读取 |
| trimStream | 布尔值 | true | 是否修剪流 |
输出记录
为输入流中的每条消息创建一个记录。
每个记录都是一个 HashMap<String, Object>，包含以下字段
| 名称 | 类型 | 描述 |
|---|---|---|
| id | 字符串 | 消息的 ID |
| key | 字符串 | 流键名 |
| value | HashMap<String, byte[]> | 消息的数据 |
示例
以下示例创建一个具有默认值的 StreamReader
StreamReader reader = new StreamReader();
要更改 StreamReader 的参数值，请使用它们的 setter 方法
StreamReader reader = new StreamReader();
// Get streams for keys that match "weather"
reader.setPattern("weather");
// Run RedisGears functions after every 10 messages
reader.setBatchSize(10);