如何在气流的码头组合设置中设置PGBOUNCER

问题描述 投票:0回答:1
在这里我配置了pgbouncer

pgbouncer: image: "bitnami/pgbouncer:1.16.0" restart: always environment: POSTGRESQL_HOST: "postgres" POSTGRESQL_USERNAME: ${POSTGRES_USER} POSTGRESQL_PASSWORD: ${POSTGRES_PASSWORD} POSTGRESQL_PORT: ${PSQL_PORT} PGBOUNCER_DATABASE: ${POSTGRES_DB} PGBOUNCER_AUTH_TYPE: "trust" PGBOUNCER_IGNORE_STARTUP_PARAMETERS: "extra_float_digits" ports: - '1234:1234' depends_on: - postgres
PGBOUNCER日志看起来像这样:

pgbouncer 13:29:13.87 pgbouncer 13:29:13.87 Welcome to the Bitnami pgbouncer container pgbouncer 13:29:13.87 Subscribe to project updates by watching https://github.com/bitnami/bitnami-docker-pgbouncer pgbouncer 13:29:13.87 Submit issues and feature requests at https://github.com/bitnami/bitnami-docker-pgbouncer/issues pgbouncer 13:29:13.88 pgbouncer 13:29:13.89 INFO ==> ** Starting PgBouncer setup ** pgbouncer 13:29:13.91 INFO ==> Validating settings in PGBOUNCER_* env vars... pgbouncer 13:29:13.91 WARN ==> You set the environment variable PGBOUNCER_AUTH_TYPE=trust. For safety reasons, do not use this flag in a production environment. pgbouncer 13:29:13.91 INFO ==> Initializing PgBouncer... pgbouncer 13:29:13.92 INFO ==> Waiting for PostgreSQL backend to be accessible pgbouncer 13:29:13.92 INFO ==> Backend postgres:9876 accessible pgbouncer 13:29:13.93 INFO ==> Configuring credentials pgbouncer 13:29:13.93 INFO ==> Creating configuration file pgbouncer 13:29:14.06 INFO ==> Loading custom scripts... pgbouncer 13:29:14.06 INFO ==> ** PgBouncer setup finished! ** pgbouncer 13:29:14.08 INFO ==> ** Starting PgBouncer ** 2022-10-25 13:29:14.089 UTC [1] LOG kernel file descriptor limit: 1048576 (hard: 1048576); max_client_conn: 100, max expected fd use: 152 2022-10-25 13:29:14.089 UTC [1] LOG listening on 0.0.0.0:1234 2022-10-25 13:29:14.089 UTC [1] LOG listening on unix:/tmp/.s.PGSQL.1234 2022-10-25 13:29:14.089 UTC [1] LOG process up: PgBouncer 1.16.0, libevent 2.1.8-stable (epoll), adns: c-ares 1.14.0, tls: OpenSSL 1.1.1d 10 Sep 2019 2022-10-25 13:30:14.090 UTC [1] LOG stats: 0 xacts/s, 0 queries/s, in 0 B/s, out 0 B/s, xact 0 us, query 0 us, wait 0 us 2022-10-25 13:31:14.090 UTC [1] LOG stats: 0 xacts/s, 0 queries/s, in 0 B/s, out 0 B/s, xact 0 us, query 0 us, wait 0 us 2022-10-25 13:32:14.090 UTC [1] LOG stats: 0 xacts/s, 0 queries/s, in 0 B/s, out 0 B/s, xact 0 us, query 0 us, wait 0 us 2022-10-25 13:33:14.090 UTC [1] LOG stats: 0 xacts/s, 0 queries/s, in 0 B/s, out 0 B/s, xact 0 us, query 0 us, wait 0 us 2022-10-25 13:34:14.089 UTC [1] LOG stats: 0 xacts/s, 0 queries/s, in 0 B/s, out 0 B/s, xact 0 us, query 0 us, wait 0 us 2022-10-25 13:35:14.090 UTC [1] LOG stats: 0 xacts/s, 0 queries/s, in 0 B/s, out 0 B/s, xact 0 us, query 0 us, wait 0 us 2022-10-25 13:36:14.090 UTC [1] LOG stats: 0 xacts/s, 0 queries/s, in 0 B/s, out 0 B/s, xact 0 us, query 0 us, wait 0 us 2022-10-25 13:37:14.090 UTC [1] LOG stats: 0 xacts/s, 0 queries/s, in 0 B/s, out 0 B/s, xact 0 us, query 0 us, wait 0 us 2022-10-25 13:38:14.090 UTC [1] LOG stats: 0 xacts/s, 0 queries/s, in 0 B/s, out 0 B/s, xact 0 us, query 0 us, wait 0 us 2022-10-25 13:39:14.089 UTC [1] LOG stats: 0 xacts/s, 0 queries/s, in 0 B/s, out 0 B/s, xact 0 us, query 0 us, wait 0 us

该服务似乎运行正常,但我认为它无能为力。在气流文档中,关于此的信息很少,我不确定要更改什么。
我应该更改Docker-Compose文件中的PGBOUNCER设置吗?

我应该更改airflow__database__sql_alchemy_conn变量吗?

update1:
我编辑了工人节点的Docker-compose.yml,并将DB端口更改为PGBOUNCER端口。之后,我在弹跳器日志上有一些流量。气流任务是排队的,并且没有使用此配置来进行选择,因此仍然有问题。我没有编辑启动Web服务器,调度程序等的Docker-Compose YAML,不知道如何。
AIRFLOW__DATABASE__SQL_ALCHEMY_CONN: postgresql+psycopg2://<XXX>@${AIRFLOW_WEBSERVER_URL}:${PGBOUNCER_PORT}/airflow AIRFLOW__CELERY__RESULT_BACKEND: db+postgresql://<XXX>@${AIRFLOW_WEBSERVER_URL}:${PGBOUNCER_PORT}/airflow

更改后的pgbouncer日志:

    2022-10-26 11:46:22.517 UTC [1] LOG stats: 0 xacts/s, 0 queries/s, in 0 B/s, out 0 B/s, xact 0 us, query 0 us, wait 0 us 2022-10-26 11:47:22.517 UTC [1] LOG stats: 0 xacts/s, 0 queries/s, in 0 B/s, out 0 B/s, xact 0 us, query 0 us, wait 0 us 2022-10-26 11:48:22.517 UTC [1] LOG stats: 0 xacts/s, 0 queries/s, in 0 B/s, out 0 B/s, xact 0 us, query 0 us, wait 0 us 2022-10-26 11:49:22.519 UTC [1] LOG stats: 0 xacts/s, 0 queries/s, in 0 B/s, out 0 B/s, xact 0 us, query 0 us, wait 0 us 2022-10-26 11:50:22.518 UTC [1] LOG stats: 0 xacts/s, 0 queries/s, in 0 B/s, out 0 B/s, xact 0 us, query 0 us, wait 0 us 2022-10-26 11:51:22.516 UTC [1] LOG stats: 0 xacts/s, 0 queries/s, in 0 B/s, out 0 B/s, xact 0 us, query 0 us, wait 0 us 2022-10-26 11:51:52.356 UTC [1] LOG C-0x5602cf8ab180: <XXX>@<IP:PORT> login attempt: db=airflow user=airflow tls=no 2022-10-26 11:51:52.359 UTC [1] LOG S-0x5602cf8b1f20: <XXX>@<IP:PORT> new connection to server (from <IP:PORT>) 2022-10-26 11:51:52.410 UTC [1] LOG C-0x5602cf8ab180: <XXX>@<IP:PORT> closing because: client close request (age=0s) 2022-10-26 11:51:52.834 UTC [1] LOG C-0x5602cf8ab180: <XXX>@<IP:PORT> login attempt: db=airflow user=airflow tls=no 2022-10-26 11:51:52.845 UTC [1] LOG C-0x5602cf8ab180: <XXX>@<IP:PORT> closing because: client close request (age=0s) 2022-10-26 11:51:56.752 UTC [1] LOG C-0x5602cf8ab180: <XXX>@<IP:PORT> login attempt: db=airflow user=airflow tls=no 2022-10-26 11:51:57.393 UTC [1] LOG C-0x5602cf8ab3b0: <XXX>@<IP:PORT> login attempt: db=airflow user=airflow tls=no 2022-10-26 11:51:57.394 UTC [1] LOG S-0x5602cf8b2150: <XXX>@<IP:PORT> new connection to server (from <IP:PORT>) 2022-10-26 11:51:59.906 UTC [1] LOG C-0x5602cf8ab180: <XXX>@<IP:PORT> closing because: client close request (age=3s) 2022-10-26 11:52:00.642 UTC [1] LOG C-0x5602cf8ab3b0: <XXX>@<IP:PORT> closing because: client close request (age=3s)
  1. 这为我工作

airflow__core__sql_alchemy_conn= postgresql+psycopg2://postgres:postgres@pgbouncer:5432/airflow

Airflow__database__sql_alchemy_conn= postgresql+psycopg2:// postgres:postgres@pgbouncer:5432/airflow
postgresql docker-compose airflow pgbouncer
1个回答
0
投票

© www.soinside.com 2019 - 2025. All rights reserved.