MongoDB无法使用env变量连接到Node JS(kubernetes)

内容来源于 Stack Overflow,并遵循CC BY-SA 3.0许可协议进行翻译与使用

  • 回答 (1)
  • 关注 (0)
  • 查看 (157)

我有一个基于容器的应用程序运行节点JS,我的后端是一个mongoDB容器。

基本上,我打算做的是在kubernetes中运行它。

我已将此作为单独的容器部署在我当前的环境中,并且工作正常。我有一个mongoDB容器和一个节点JS容器。

连接这两个我会做

docker run -d --link=mongodb:mongodb -e MONGODB_URL='mongodb://mongodb:27017/user' -p 4000:4000 e922a127d049 

我的connection.js运行如下,它将采用MONGODB_URL并传入我的节点JS容器中的process.env。然后我的connection.js会将MONGODB_URL提取到mongoDbUrl中,如下所示。

const mongoClient = require('mongodb').MongoClient;
const mongoDbUrl = process.env.MONGODB_URL;
//console.log(process.env.MONGODB_URL)
let mongodb;

function connect(callback){
    mongoClient.connect(mongoDbUrl, (err, db) => {
        mongodb = db;
        callback();
    });
}
function get(){
    return mongodb;
}

function close(){
    mongodb.close();
}

module.exports = {
    connect,
    get,
    close
};

要在k8s上部署,我已经写了一个yaml文件

1)web控制器2)web服务3)mongoDB控制器4)mongoDB服务

这是我目前的mongoDB控制器

apiVersion: extensions/v1beta1
kind: Deployment
metadata:
  name: mongo-deployment
spec:
  replicas: 1
  template:
    metadata:
      labels:
        name: mongo
    spec:
      containers:
      - image: mongo:latest
        name: mongo
        ports:
        - name: mongo
          containerPort: 27017
          hostPort: 27017

我的mongoDB服务

apiVersion: v1
kind: Service
metadata:
  labels:
    name: mongodb
  name: mongodb
spec:
  ports:
    - port: 27017
      targetPort: 27017
  selector:
    name: mongo


我的网络控制器

apiVersion: v1
kind: ReplicationController
metadata:
  labels:
    name: web
  name: web-controller
spec:
  replicas: 1
  selector:
    name: web
  template:
    metadata:
      labels:
        name: web
    spec:
      containers:
      - image: leexha/node_demo:21
        env:
        - name: MONGODB_URL
          value: "mongodb://mongodb:27017/user"
        name: web
        ports:
        - containerPort: 4000
          name: node-server

和我的网络服务

apiVersion: v1
kind: Service
metadata:
  name: web
  labels:
    name: web
spec:
  type: NodePort
  ports:
    - port: 4000
      targetPort: 4000
      protocol: TCP
  selector:
    name: web

我能够在我的本地kubernetes集群上部署所有服务和pod。

但是,当我尝试通过nodeport访问Web应用程序时,它告诉我mongoDB存在连接错误。

TypeError: Cannot read property 'collection' of null
    at /app/app.js:24:17
    at Layer.handle [as handle_request] 

这是app.js的节点JS代码

var bodyParser = require('body-parser')
, MongoClient = require('mongodb').MongoClient
, PORT = 4000
, instantMongoCrud = require('express-mongo-crud') // require the module
, express = require('express')
, app = express()
, path = require('path')
, options = { //specify options
    host: `localhost:${PORT}`
}
, db = require('./connection')


// connection to database
db.connect(() => {

    app.use(bodyParser.json()); // add body parser
    app.use(bodyParser.urlencoded({ extended: true }));
    //console.log('Hello ' + process.env.MONGODB_URL)

    // get function 
    app.get('/', function(req, res) {
        db.get().collection('users').find({}).toArray(function(err, data){
            if (err)
                console.log(err)
            else
                res.render('../views/pages/index.ejs',{data:data});
        });
    });

显然,当我的节点JS应用程序无法读取mongoDB服务时,这是一个错误。

我起初以为我的MONGODB_URL没有设置在我的容器中。但是,当我使用检查nodeJS容器时

kubectl exec -it web-controller-r269f /bin/bash

并回复我的MONGODB_URL它返回mongodb:// mongodb:27017 / user这是正确的。

我很不确定我做错了什么,因为我很确定我已按顺序完成所有工作,而我的网络部署正在与mongoDB服务进行通信。有帮助吗?对不起我还在学习kubernetes,请原谅任何错误

提问于
用户回答回答于

[编辑]

对不起我的坏,连接字符串mongodb://mongodb:27017实际上会工作。我尝试使用dns查询该名称,即使没有指定“.default.svc ...”也可以解析为正确的IP地址。

root@web-controller-mlplb:/app# host mongodb mongodb.default.svc.cluster.local has address 10.108.119.125

@Anshul Jindal是正确的,你有竞争条件,在数据库pod之前首先加载web pod。你可能正在kubectl apply -f .尝试在kubectl delete -f .包含那些yaml的文件夹中进行重置。然后kubectl apply数据库首先显示,然后在几秒后,kubectl apply网络显示。在运行pod之前,您还可以使用Init Containers来检查mongo服务何时就绪。或者,您也可以在node.js应用程序中进行检查。

在Node.js中等待mongodb服务的示例

在您的connection.js文件中,您可以更改connect函数,以便在第一次失败时(即由于mongodb服务/ pod尚未可用),它将每3秒重试一次,直到建立连接为止。这样,您甚至不必担心应用kubernetes清单的加载顺序,您可以这样做kubectl apply -f .

let RECONNECT_INTERVAL = 3000

function connect(callback){
      mongoClient.connect(mongoDbUrl, (err, db) => {
        if (err) {
          console.log("attempting to reconnect to " + mongoDbUrl)
          setTimeout(connect.bind(this, callback), RECONNECT_INTERVAL)
          return
        } else {
          mongodb = db;
          callback();
        }
      });
}

扫码关注云+社区

领取腾讯云代金券