JetStream KV

关于 JetStream KV 状态存储组件的详细信息

组件格式

要设置 JetStream KV 状态存储，需创建一个类型为 state.jetstream 的组件。请参阅此指南了解如何创建和应用状态存储配置。

apiVersion: dapr.io/v1alpha1
kind: Component
metadata:
  name: <NAME>
spec:
  type: state.jetstream
  version: v1
  metadata:
  - name: natsURL
    value: "nats://localhost:4222"
  - name: jwt
    value: "eyJhbGciOiJ...6yJV_adQssw5c" # 可选。用于去中心化 JWT 认证
  - name: seedKey
    value: "SUACS34K232O...5Z3POU7BNIL4Y" # 可选。用于去中心化 JWT 认证
  - name: bucket
    value: "<bucketName>"

规范元数据字段

字段必需详情示例
natsURLYNATS 服务器地址 URL“nats://localhost:4222”
jwtNNATS 去中心化认证 JWT“eyJhbGciOiJ...6yJV_adQssw5c”
seedKeyNNATS 去中心化认证种子密钥“SUACS34K232O...5Z3POU7BNIL4Y”
bucketYJetStream KV 存储桶名称"<bucketName>"

创建 NATS 服务器

你可以使用 Docker 在本地运行启用了 JetStream 的 NATS 服务器：

docker run -d -p 4222:4222 nats:latest -js

然后可以使用客户端端口与服务器交互：localhost:4222。

使用 helm 在 Kubernetes 上安装 NATS JetStream：

helm repo add nats https://nats-io.github.io/k8s/helm/charts/
helm install my-nats nats/nats

这会在 default 命名空间中安装一个单节点 NATS 服务器。要与 NATS 交互，可以使用以下命令查找服务：kubectl get svc my-nats。

创建 JetStream KV 存储桶

需要创建一个键值存储桶，这可以通过 NATS CLI 轻松完成。

nats kv add <bucketName>

相关链接