The documentation you are viewing is for Dapr v1.13 which is an older version of Dapr. For up-to-date documentation, see the latest version.
状态生存时间(TTL)
Dapr 允许对每个状态设置请求的生存时间(TTL)。 这意味着应用程序可以为每个存储的状态设置生存时间,并且在过期后无法检索这些状态。
对于支持的状态存储,只需在发布消息时设置 ttlInSeconds
元数据。 其他的状态存储将忽略这个值。 对于一些状态存储,您可以在每个表/容器的基础上指定一个默认的到期时间。
原生状态 TTL 支持
当状态 TTL 在状态存储组件中具有本机支持时,Dapr 会转发 TTL 配置,而不会添加任何额外逻辑,保持可预测的行为。 当组件对过期状态的处理方式不同时,这很有帮助。
当没有指定TTL时,将保留状态存储的默认行为。
绕过全局定义的 TTL 进行显式持久化
持久状态适用于允许您指定用于所有数据的默认 TTL 的所有状态存储,或者:
- 通过 Dapr 组件设置全局 TTL 值,或
- 在 Dapr 之外创建状态存储并设置全局 TTL 值时。
当未指定特定的 TTL 时,数据将在全局 TTL 时间段之后过期。 Dapr 没有促进这一点。
此外,所有状态存储还支持选择_显式_持久化数据。 这意味着您可以忽略默认的数据库策略(可能是在 Dapr 外部设置的,或通过 Dapr 组件设置的),以无限期地保留给定的数据库记录。 您可以通过将ttlInSeconds
设置为-1来实现此目的。 此值表示忽略任何设置的TTL值。
受支持的组件
请参阅 TTL 列 状态存储组件指南.
如何使用Dapr扩展来开发和运行Dapr应用程序
您可以在状态存储设置请求的元数据中设置状态TTL:
#dependencies
from dapr.clients import DaprClient
#code
DAPR_STORE_NAME = "statestore"
with DaprClient() as client:
client.save_state(DAPR_STORE_NAME, "order_1", str(orderId), state_metadata={
'ttlInSeconds': '120'
})
要启动 Dapr sidecar 并运行上述示例应用程序,然后运行类似以下命令:
dapr run --app-id orderprocessing --app-port 6001 --dapr-http-port 3601 --dapr-grpc-port 60001 -- python3 OrderProcessingService.py
// dependencies
using Dapr.Client;
// code
await client.SaveStateAsync(storeName, stateKeyName, state, metadata: new Dictionary<string, string>() {
{
"ttlInSeconds", "120"
}
});
要启动 Dapr sidecar 并运行上述示例应用程序,然后运行类似以下命令:
dapr run --app-id orderprocessing --app-port 6001 --dapr-http-port 3601 --dapr-grpc-port 60001 dotnet run
// dependencies
import (
dapr "github.com/dapr/go-sdk/client"
)
// code
md := map[string]string{"ttlInSeconds": "120"}
if err := client.SaveState(ctx, store, "key1", []byte("hello world"), md); err != nil {
panic(err)
}
要启动 Dapr sidecar 并运行上述示例应用程序,然后运行类似以下命令:
dapr run --app-id orderprocessing --app-port 6001 --dapr-http-port 3601 --dapr-grpc-port 60001 go run .
curl -X POST -H "Content-Type: application/json" -d '[{ "key": "order_1", "value": "250", "metadata": { "ttlInSeconds": "120" } }]' http://localhost:3601/v1.0/state/statestore
Invoke-RestMethod -Method Post -ContentType 'application/json' -Body '[{"key": "order_1", "value": "250", "metadata": {"ttlInSeconds": "120"}}]' -Uri 'http://localhost:3601/v1.0/state/statestore'
相关链接
- 查看state API参考指南。
- 了解如何 使用键值对来持久保存状态.
- 状态存储组件列表.
- 阅读API参考。
Feedback
Was this page helpful?
Glad to hear it! Please tell us how we can improve.
Sorry to hear that. Please tell us how we can improve.