如何解决如何使用 dapr python sdk add_or_update_state 函数?
我想在不覆盖现有键的情况下更新给定的 state_name; set_state 和 save_state 函数的组合总是覆盖所有键。
函数 add_or_update 似乎做了我想要的;更新如果存在类型逻辑,虽然我似乎无法理解 update_value_factory 参数。
有人可以提供一个 add_or_update 函数的工作示例吗?
https://github.com/dapr/python-sdk/blob/master/dapr/actor/runtime/state_manager.py
async def add_or_update_state(
self,state_name: str,value: T,update_value_factory: Callable[[str,T],T]) -> T:
if not callable(update_value_factory):
raise AttributeError('update_value_factory is not callable')
if state_name in self._state_change_tracker:
state_Metadata = self._state_change_tracker[state_name]
if state_Metadata.change_kind == StateChangeKind.remove:
self._state_change_tracker[state_name] = \
StateMetadata(value,StateChangeKind.update)
return value
new_value = update_value_factory(state_name,state_Metadata.value)
state_Metadata.value = new_value
if state_Metadata.change_kind == StateChangeKind.none:
state_Metadata.change_kind = StateChangeKind.update
self._state_change_tracker[state_name] = state_Metadata
return new_value
has_value,val = await self._actor.runtime_ctx.state_provider.try_load_state(
self._type_name,self._actor.id.id,state_name)
if has_value:
new_value = update_value_factory(state_name,val)
self._state_change_tracker[state_name] = \
StateMetadata(new_value,StateChangeKind.update)
return new_value
self._state_change_tracker[state_name] = \
StateMetadata(value,StateChangeKind.add)
return value
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。