PostgreSQL

组件格式

要配置 PostgreSQL 作为配置存储，您需要创建一个类型为 configuration.postgresql 的组件。

apiVersion: dapr.io/v1alpha1
kind: Component
metadata:
  name: <NAME>
spec:
  type: configuration.postgresql
  version: v1
  metadata:
    # 连接字符串
    - name: connectionString
      value: "host=localhost user=postgres password=example port=5432 connect_timeout=10 database=config"
    # 存储配置信息的表名
    - name: table
      value: "[your_configuration_table_name]" 
    # 数据库操作的超时时间，以秒为单位（可选）
    #- name: timeoutInSeconds
    #  value: 20
    # 存储状态的表名（可选）
    #- name: tableName
    #  value: "state"
    # 存储 Dapr 使用的元数据的表名（可选）
    #- name: metadataTableName
    #  value: "dapr_metadata"
    # 清理过期行的间隔时间，以秒为单位（可选）
    #- name: cleanupIntervalInSeconds
    #  value: 3600
    # 该组件池化的最大连接数（可选）
    #- name: maxConns
    #  value: 0
    # 连接关闭前的最大空闲时间（可选）
    #- name: connectionMaxIdleTime
    #  value: 0
    # 控制查询执行的默认模式。（可选）
    #- name: queryExecMode
    #  value: ""
    # 如果希望使用 PostgreSQL 作为 actor 的状态存储，请取消注释此项（可选）
    #- name: actorStateStore
    #  value: "true"

规格元数据字段

使用连接字符串进行身份验证

以下元数据选项是通过 PostgreSQL 连接字符串进行身份验证时必需的。

使用 Microsoft Entra ID 进行身份验证

使用 Microsoft Entra ID 进行身份验证支持 Azure Database for PostgreSQL。Dapr 支持的所有身份验证方法都可以使用，包括客户端凭据（“服务主体”）和托管身份。

使用 AWS IAM 进行身份验证

使用 AWS IAM 进行身份验证支持所有版本的 PostgreSQL 类型组件。 连接字符串中指定的用户必须是数据库中已存在的用户，并且是授予 rds_iam 数据库角色的 AWS IAM 启用用户。 身份验证基于 AWS 身份验证配置文件，或提供的 AccessKey/SecretKey。 AWS 身份验证令牌将在其到期时间之前动态旋转。

其他元数据选项

设置 PostgreSQL 作为配置存储

1. 启动 PostgreSQL 数据库。

2. 连接到 PostgreSQL 数据库并设置具有以下模式的配置表：

   字段	数据类型	可为空	详情
   KEY	VARCHAR	N	持有配置属性的 "Key"
   VALUE	VARCHAR	N	持有配置属性的值
   VERSION	VARCHAR	N	持有配置属性的版本
   METADATA	JSON	Y	以 JSON 形式持有元数据

   CREATE TABLE IF NOT EXISTS table_name (
     KEY VARCHAR NOT NULL,
     VALUE VARCHAR NOT NULL,
     VERSION VARCHAR NOT NULL,
     METADATA JSON
   );
   

3. 在配置表上创建一个 TRIGGER。创建 TRIGGER 的示例函数如下：

   CREATE OR REPLACE FUNCTION notify_event() RETURNS TRIGGER AS $$
       DECLARE 
           data json;
           notification json;
   
       BEGIN
   
           IF (TG_OP = 'DELETE') THEN
               data = row_to_json(OLD);
           ELSE
               data = row_to_json(NEW);
           END IF;
   
           notification = json_build_object(
                             'table',TG_TABLE_NAME,
                             'action', TG_OP,
                             'data', data);
           PERFORM pg_notify('config',notification::text);
           RETURN NULL; 
       END;
   $$ LANGUAGE plpgsql;
   

4. 使用标记为 data 的字段封装数据创建触发器：

   notification = json_build_object(
     'table',TG_TABLE_NAME,
     'action', TG_OP,
     'data', data
   );
   

5. 在订阅配置通知时，应使用作为 pg_notify 属性提到的通道。

6. 由于这是一个通用创建的触发器，将此触发器映射到 configuration table。

   CREATE TRIGGER config
   AFTER INSERT OR UPDATE OR DELETE ON configtable
       FOR EACH ROW EXECUTE PROCEDURE notify_event();
   

7. 在订阅请求中添加一个额外的元数据字段，键为 pgNotifyChannel，值应设置为在 pg_notify 中提到的相同 channel name。从上面的示例中，它应设置为 config。

curl -l 'http://<host>:<dapr-http-port>/configuration/mypostgresql/subscribe?key=<keyname1>&key=<keyname2>&metadata.pgNotifyChannel=<channel name>'

相关链接

• Dapr 组件的基本模式
• 配置构建块