如何使用 dapr python sdk add_or_update_state 函数?

如何解决如何使用 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 举报,一经查实,本站将立刻删除。

相关推荐


Selenium Web驱动程序和Java。元素在(x,y)点处不可单击。其他元素将获得点击?
Python-如何使用点“。” 访问字典成员?
Java 字符串是不可变的。到底是什么意思?
Java中的“ final”关键字如何工作?(我仍然可以修改对象。)
“loop:”在Java代码中。这是什么,为什么要编译?
java.lang.ClassNotFoundException:sun.jdbc.odbc.JdbcOdbcDriver发生异常。为什么?
这是用Java进行XML解析的最佳库。
Java的PriorityQueue的内置迭代器不会以任何特定顺序遍历数据结构。为什么?
如何在Java中聆听按键时移动图像。
Java“Program to an interface”。这是什么意思?
Java在半透明框架/面板/组件上重新绘画。
Java“ Class.forName()”和“ Class.forName()。newInstance()”之间有什么区别?
在此环境中不提供编译器。也许是在JRE而不是JDK上运行?
Java用相同的方法在一个类中实现两个接口。哪种接口方法被覆盖?
Java 什么是Runtime.getRuntime()。totalMemory()和freeMemory()?
java.library.path中的java.lang.UnsatisfiedLinkError否*****。dll
JavaFX“位置是必需的。” 即使在同一包装中
Java 导入两个具有相同名称的类。怎么处理?
Java 是否应该在HttpServletResponse.getOutputStream()/。getWriter()上调用.close()?
Java RegEx元字符(。)和普通点?