小编Alp*_*esh的帖子

我想了解/获取有关如何为 RabbitMQ 队列消费者设置活性探针的意见。我不确定如何验证消费者是否仍在处理来自队列的消息。我已经尝试在互联网上寻找一些线索，但找不到任何线索。所以只是在这里问一个问题，看看是否有人有任何想法。

我想确保正常工作的代码块是

                var consumer = new EventingBasicConsumer(channel);
                consumer.Received += (model, ea) =>
                {
                    var body = ea.Body;
                    var message = Encoding.UTF8.GetString(body);
                    Console.WriteLine($"Message Received: {message}");
                };

谢谢。

我有一个 configMap 文件：

apiVersion: v1
kind: ConfigMap
metadata:
  labels:
    owner: testdb
  name: testdb-configmap 
data:
  host: postgres
  port: "5432" 

和一个秘密文件：

aapiVersion: v1
kind: Secret
type: Opaque
metadata:
  labels:
    owner: testdb
  name: testdb-secret
  namespace: test
data:
  user: dGVzdA==
  pwd: dGVzdA==

我想构建一个环境变量，CONNECTION_STRING如下所示：

env:
 - name: CONNECTION_STRING
   value: "Host=<host-from-configmap>;Username=<user-from-secret>;Password=<password-from-secret>;Port=<port-from-configmap>;Pooling=False;"

我想知道这是否可能，如果可以，那么如何？我也考虑过使用.tpl（命名模板），但找不到方法。

笔记

由于我无权访问图像，因此CONNECTION_STRING我必须以这种方式构建它。这些配置映射和秘密文件也将保持这样。