如何使用 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 (将#修改为@）