Сбой аутентификации пароля при подключении к RDS Postgres с использованием учетных данных, сгенерированных AWS - PullRequest
Новая
       8

Сбой аутентификации пароля при подключении к RDS Postgres с использованием учетных данных, сгенерированных AWS

0 голосов
/ 12 апреля 2020

Я пытаюсь подключиться к базе данных RDS Postgres из экземпляра ECS, но получаю error: password authentication failed for user. Оба настроены с использованием AWS CDK. Я только предоставляю имя пользователя базы данных и позволяю AWS сгенерировать пароль, который предоставляется экземпляру ECS через секретную переменную env. Я регистрирую env vars в экземпляре ECS и вижу, что он получает информацию о соединении с базой данных, включая сгенерированные учетные данные.

Вот код моего приложения 

import * as dotenv from "dotenv";
import * as Koa from "koa";
import * as Knex from "knex";

dotenv.config();
const { env } = process;
const port = parseInt(env.PORT || "3000", 10);

function getDatabaseConnection(): Knex.Config["connection"] {
  const {
    DATABASE_URL,
    DATABASE_HOST,
    DATABASE_NAME,
    DATABASE_CREDENTIALS,
    DATABASE_PORT = "5432",
  } = env;

  if (DATABASE_URL) {
    return DATABASE_URL;
  }

  if (!DATABASE_HOST)
    throw new Error("Missing required env var: DATABASE_HOST");
  if (!DATABASE_NAME)
    throw new Error("Missing required env var: DATABASE_NAME");
  if (!DATABASE_CREDENTIALS)
    throw new Error("Missing required env var: DATABASE_CREDENTIALS");

  const { username, password } = JSON.parse(DATABASE_CREDENTIALS);

  return {
    host: DATABASE_HOST,
    user: username,
    password: password,
    port: parseInt(DATABASE_PORT, 10),
    database: DATABASE_NAME,
  };
}

main();
async function main() {
  const databaseConnection = getDatabaseConnection();

  console.log(`Connecting to database:`, databaseConnection);

  let db: Knex | null = Knex({
    client: "pg",
    connection: databaseConnection,
    acquireConnectionTimeout: 5000,
  });

  await db.raw("SELECT 10 + 15").catch((error) => {
    console.log("Test query failed", error);
    db = null;
  });

  const app = new Koa().use(async (context) => {
    try {
      context.response.body = {
        hello: "world",
        queryResult: db ? await db.raw("SELECT 10 + 15") : null,
      };
    } catch (error) {
      context.response.body = {
        error: { ...error, message: error.message },
      };
    }
  });

  await new Promise((resolve) => app.listen(port, resolve));

  console.log(`Listening on port ${port}`);
}

И мой AWS стек CDK 

import { v4 as uuid } from "uuid";
import ec2 = require("@aws-cdk/aws-ec2");
import ecs = require("@aws-cdk/aws-ecs");
import cdk = require("@aws-cdk/core");
import { RemovalPolicy } from "@aws-cdk/core";
import rds = require("@aws-cdk/aws-rds");
import ecsPatterns = require("@aws-cdk/aws-ecs-patterns");
import path = require("path");
import { Port, InstanceClass, InstanceSize } from "@aws-cdk/aws-ec2";
import { Secret } from "@aws-cdk/aws-secretsmanager";

const app = new cdk.App();
const stack = new cdk.Stack(app, process.env.STACK_NAME || "HelloWorld");
const vpc = new ec2.Vpc(stack, "MyVpc", { maxAzs: 2 });
const cluster = new ecs.Cluster(stack, "Cluster", { vpc });

const port = 3000;
const databasePort = 5432;
const databaseUser = "app";
const databaseName = "app_db";

cluster.addCapacity("cluser_capacity", {
  instanceType: ec2.InstanceType.of(InstanceClass.T2, InstanceSize.MICRO),
  maxCapacity: 1,
});

const database = new rds.DatabaseInstance(stack, "AppDatabase", {
  vpc,
  engine: rds.DatabaseInstanceEngine.POSTGRES,
  instanceClass: ec2.InstanceType.of(
    ec2.InstanceClass.T2,
    ec2.InstanceSize.MICRO
  ),
  removalPolicy: RemovalPolicy.DESTROY,
  databaseName: databaseName,
  masterUsername: databaseUser,
  deletionProtection: false,
  port: databasePort,
});

const apiService = new ecsPatterns.ApplicationLoadBalancedFargateService(
  stack,
  "AppService",
  {
    cluster,
    publicLoadBalancer: true,
    taskImageOptions: {
      environment: {
        PORT: port.toString(),
        DATABASE_PORT: databasePort.toString(),
        DATABASE_HOST: database.dbInstanceEndpointAddress,
        DATABASE_USER: databaseUser,
        DATABASE_NAME: databaseName,
      },
      secrets: database.secret
        ? {
            DATABASE_CREDENTIALS: ecs.Secret.fromSecretsManager(
              database.secret
            ),
          }
        : {},
      containerPort: port,
      image: ecs.ContainerImage.fromAsset(
        path.resolve(__dirname, "..", "local-image")
      ),
    },
  }
);

database.connections.allowFrom(apiService.service, Port.tcp(databasePort));

app.synth();

Почему не работают имя пользователя / пароль, сгенерированные RDS?

...