redis - 如何在事务中选择性地执行多个更新(不是添加或更新)?
问题描述
我有这个方法:
public async Task<bool> UpdateIfExist<T>(string cacheKey, IDictionary<string, T> dictionary)
{
ITransaction tran = m_connection.GetDatabase().CreateTransaction();
List<HashEntry> hashEntries = new List<HashEntry>();
foreach (KeyValuePair<string, T> keyValuePair in dictionary)
{
tran.AddCondition(Condition.HashExists(cacheKey, keyValuePair.Key)); // <-- this guy is the problem
HashEntry hashEntry = GetHashEntry(keyValuePair);
hashEntries.Add(hashEntry);
}
bool committed = await tran.ExecuteAsync();
if (committed)
{
await tran.HashSetAsync(cacheKey, hashEntries.ToArray()));
}
return committed;
}
我的意图是执行纯更新,即更新那些dictionary
也存在于缓存哈希中的键。我不希望将新的键值对dictionary
插入到缓存的哈希中。但是上面执行的是“全有或全无”更新,也就是说,如果缓存的哈希中缺少字典中的任何一个键,则不会更新任何内容。
例如,假设我的 Redis 缓存中有这个哈希:
myKey foo bar
goo baz
说,这是我的输入字典:
foo newBar
qoo qux
在我调用我的方法之后..
预期在缓存中:
myKey foo newBar // updated since the field exists in hash
goo baz
实际的:
myKey foo bar // no change to cache
goo baz
注意:如果 Lua 脚本是我会尝试的唯一方法,但主要是寻找原生 SE.Redis API 方法。
解决方案
没有本地 redis 方法可以直接执行此操作,因此没有本地 SE-Redis 方法可以直接执行此操作。我们在这里真正想要的是一个XX
修饰符(请参阅SET
我的意思),但这在任何哈希命令上都不存在 - only NX
,这与您想要的相反(NX
是“当不存在时”)。
你可以通过以下方式在没有 Lua 的情况下做到这一点:
- 检查每个第一个是否存在
- 修剪你的更新集
- 创建仅包含修剪更新的事务,并带有断言检查的条件
- ETC
但这是很多往返和操作,并且由于数据更改冲突而失败的可能性很高。因此,我想说最好的方法是使用 Lua(对于您希望成为原子的多个相关操作通常是这种情况)。我会在 中发送一个值KEYS
,每个条目中的一对值ARGV
,并在 Lua 中循环,本质上(完全未经测试 - 甚至可能不是有效的语法)
for i=1, #ARGV, 2 do
if redis.call('hexists', KEYS[1], ARGV[i]) == 1then
redis.call('hset', KEYS[1], ARGV[i], ARGV[i+1])
end
end
推荐阅读
- java - 添加自定义 Eclipse 完成,如 sysout
- php - 从表单中获取值并更新表 sql
- .net - .Net Core 中的 Http POST 请求
- python - 用python创建简历(html和pdf)
- raspberry-pi - 在 Archlinux 上作为服务运行时,scanbd 有 30 秒的延迟
- python - 有效函数名称的未解决引用 - Python
- button - 努力从 observbleArrayList 获取内容以显示
- python - 为什么我的协方差计算不精确
- php - Reactjs 和 Laravel 之间的会话问题,(错误 401 - 未验证)
- python - 在 Python 中从文本文件中提取数据