如何在Postgres中记录微服务发送的correlation id（关联ID）

完全可以实现，这也是分布式系统全链路日志排查的标准实践之一，具体可以通过以下两种常用方案落地：

• 方案1：复用PostgreSQL内置的application_name参数
  无需修改数据库核心配置，在微服务处理每个请求时，拿到correlation id后直接对当前数据库会话执行SET application_name = '${你的correlation_id}';即可，也可以在创建数据库连接时动态写入连接参数。PostgreSQL默认的日志格式会自动携带application_name字段，Fluentd采集日志时只需配置对应解析规则就能提取该字段，存入ES后即可和应用、微服务日志通过该ID关联检索。如果担心application_name被其他逻辑占用，也可以在值里加固定前缀区分，比如corr_id:abc1234xxxx。
• 方案2：使用自定义GUC参数
  先修改PostgreSQL的postgresql.conf配置，新增自定义参数：custom.correlation_id = ''，重载配置生效后，就可以在会话中执行SET custom.correlation_id = '${你的correlation_id}';写入ID。同时修改log_line_prefix配置，把自定义参数加入日志输出格式，比如在原有前缀后追加%n(custom.correlation_id)，即可让ID固定输出到数据库日志的指定位置，解析更稳定。

注意事项 #

• 如果微服务使用了数据库连接池，务必在每次请求占用连接时重新设置correlation id，请求归还连接前清空该值，避免不同请求的ID混用导致链路混乱
• EFK栈配置时，建议把correlation id设置为Elasticsearch的索引字段，后续可以直接用该ID做全链路日志的过滤、聚合，排查问题时可以一次性拉取同一个请求的应用日志、网关日志、数据库执行日志，效率提升非常明显

内容的提问来源于stack exchange，提问作者Alexander Mladzhov