Python中PubNub回调函数内打印内容无法实时显示的问题

我来帮你搞定这个困扰！首先得先纠正代码里一个小误区：你写的print(logging.info(event.message['text']))其实是多余的——logging.info本身就会输出日志内容，而print打印的是logging.info的返回值（也就是None），这部分可以直接改成logging.info(event.message['text'])。

回到核心问题：为什么只有Git Bash里会出现回调输出延迟，新消息触发后才打印之前的内容？这其实是Git Bash的终端输出缓冲策略导致的：

PubNub的回调函数是在后台线程中执行的，而Git Bash对后台线程的标准输出采用了块缓冲模式（而非行缓冲）。只有当主线程执行input()或者其他触发缓冲刷新的操作时，之前后台线程积累的输出才会被一次性打印出来。而IDLE和PowerShell默认对后台线程输出采用行缓冲，所以不会有延迟。

下面是几种可行的解决方案：

方案1：启动脚本时强制无缓冲输出 #

直接用-u参数启动Python脚本，这个参数会强制让标准输出/错误流变成无缓冲模式：

python -u your_script_name.py

方案2：在脚本中手动设置无缓冲输出 #

在脚本开头添加以下代码，修改标准输出的缓冲方式：

import sys
# 将stdout设置为行缓冲（buffering=1），确保每一行输出都实时刷新
sys.stdout = open(sys.stdout.fileno(), 'w', buffering=1)
sys.stderr = open(sys.stderr.fileno(), 'w', buffering=1)

方案3：配置Logging实时刷新 #

如果你想用logging模块输出，需要确保日志的StreamHandler会实时刷新缓冲。可以这样配置：

import logging
import sys

# 配置logging，指定输出到stdout并强制刷新
handler = logging.StreamHandler(sys.stdout)
handler.setLevel(logging.INFO)
# 强制每次日志输出后刷新
handler.flush = lambda: handler.stream.flush()

logging.basicConfig(
    level=logging.INFO,
    handlers=[handler],
    format='%(levelname)s:%(name)s:%(message)s'
)

然后回调里直接用logging.info(event.message['text'])即可。

方案4：给print添加flush参数 #

如果还是想用print输出，只需给print加上flush=True参数，强制实时刷新：

class ReceiverCallback(SubscribeCallback):
    def message(self, pnb, event):
        if event.message['text'] == 'exit':
            os._exit(0)
        print(event.message['text'], flush=True)

选其中一种方案试试，应该就能解决Git Bash里的输出延迟问题了！

内容的提问来源于stack exchange，提问作者kuco 23