Как захватить вывод команды Flask CLI в супервизоре и перенаправить его на стандартный вывод? - PullRequest
Новая
       36

Как захватить вывод команды Flask CLI в супервизоре и перенаправить его на стандартный вывод?

0 голосов
/ 16 июня 2020

Это мой Flask скрипт CLI. Он ожидает сообщений от rabbitmq и распечатывает их. 

import pika
import click
from app import app_queue
from app import RABBITMQ_USER
from app import RABBITMQ_HOST
from app import RABBITMQ_PASSWORD
from app import RABBITMQ_PASSWORD
from app import RABBITMQ_PORT
from app import RABBITMQ_VHOST
from flask import current_app
from flask.cli import with_appcontext
from threading import Event

credentials = pika.PlainCredentials(RABBITMQ_USER, RABBITMQ_PASSWORD)
parameters = pika.ConnectionParameters(RABBITMQ_HOST, RABBITMQ_PORT, RABBITMQ_VHOST, credentials)
connection = pika.BlockingConnection(parameters)
channel = connection.channel()


@app_queue.command("listen", help="Listen to default queue.")
@click.argument("queue", required=False)
@with_appcontext
def consume_message(queue):
    queue = queue if queue else 'results'
    print(f'Command is listening for "{queue}" queue.', flush=True)

    channel.queue_declare(queue, durable=True, exclusive=False)
    channel.basic_consume(queue=queue, on_message_callback=process_results)

    print(f'[*] Waiting for messages. from "{queue}" queue. To exit press CTRL+C', flush=True)
    channel.start_consuming()

    Event().wait()


def process_results(ch, method, properties, body):
    print(" [x] Received %r" % body, flush=True)
    ch.basic_ack(delivery_tag = method.delivery_tag)

Сценарий выполняется supervisord, который запускает команду flask queue listen. 

[program:app_rabbitmq]
user=root
numprocs=1
directory=/src
autostart=true
autorestart=true
process_name=%(program_name)s
redirect_stderr=true
stdout_logfile=/dev/stdout
stdout_logfile_maxbytes=0
command=flask queue listen

Как я могу перенаправить вывод команды Flask CLI на стандартный вывод, чтобы я мог увидеть его с помощью команды docker logs <my_container>?

1 Ответ

0 голосов
/ 17 июня 2020

Я нашел решение. Вот три вещи, которые я сделал.

  • Вместо перенаправления моего журнала на /dev/stdout я перенаправил его на /proc/1/fd/1

  • Я запустил supervisord в nodaemon режим supervisord -n

  • Я установил эти две переменные среды в моем docker изображении export PYTHONUNBUFFERED=True и export PYTHONIOENCODING=UTF-8

...