如何用Matplotlib绘制从网络动态获取的数据图形？

针对动态获取网络数据并在matplotlib中实时绘制的需求，以下两种方案可解决问题：

方案一：多线程+线程安全队列+交互式绘图 #

matplotlib的绘图操作需在主线程执行，可通过一个线程负责接收网络数据并存入线程安全队列，主线程循环读取队列并更新绘图，避免线程冲突。

代码示例 #

import matplotlib.pyplot as plt
import threading
import queue
import time
import random  # 模拟网络数据，实际替换为你的网络接收逻辑

# 初始化线程安全队列存储数据
data_queue = queue.Queue()

def fetch_network_data():
    """模拟网络数据接收线程"""
    i = 0
    while True:
        # 替换此处为实际网络数据获取逻辑
        x = i
        y = random.randint(0, 10)
        number = random.randint(1, 100)
        data_queue.put((x, y, number))
        i += 1
        time.sleep(1)  # 模拟数据接收间隔

# 初始化绘图
plt.ion()  # 开启交互式模式
fig, ax = plt.subplots()
ax.set_xlim(0, 20)
ax.set_ylim(0, 10)
texts = []  # 存储绘制的文本对象

# 主线程循环更新绘图
def update_plot():
    while True:
        if not data_queue.empty():
            x, y, number = data_queue.get()
            # 在(x,y)处绘制number
            text = ax.text(x, y, str(number), fontsize=12)
            texts.append(text)
            # 动态扩展x轴范围
            if x > ax.get_xlim()[1]:
                ax.set_xlim(ax.get_xlim()[0], x + 5)
            plt.draw()
            plt.pause(0.1)  # 短暂暂停让绘图更新
        time.sleep(0.05)

# 启动数据接收线程
threading.Thread(target=fetch_network_data, daemon=True).start()

# 启动绘图更新循环
update_plot()

方案二：FuncAnimation+动态数据缓冲区 #

FuncAnimation可配合动态数据列表使用，维护一个数据缓冲区，新数据到来时添加进去，动画函数根据缓冲区内容更新绘图，无需手动管理线程。

代码示例 #

import matplotlib.pyplot as plt
from matplotlib.animation import FuncAnimation
import threading
import time
import random  # 模拟网络数据

# 动态数据缓冲区
data_list = []
lock = threading.Lock()  # 线程锁保证数据修改安全

def fetch_network_data():
    """模拟网络数据接收线程"""
    i = 0
    while True:
        x = i
        y = random.randint(0, 10)
        number = random.randint(1, 100)
        with lock:
            data_list.append((x, y, number))
        i += 1
        time.sleep(1)

# 初始化绘图
fig, ax = plt.subplots()
ax.set_xlim(0, 20)
ax.set_ylim(0, 10)
texts = []

def update(frame):
    """动画更新函数"""
    with lock:
        # 获取未处理的新数据
        new_data = data_list[len(texts):]
        for x, y, number in new_data:
            text = ax.text(x, y, str(number), fontsize=12)
            texts.append(text)
            # 动态扩展x轴范围
            if x > ax.get_xlim()[1]:
                ax.set_xlim(ax.get_xlim()[0], x + 5)
    return texts

# 启动数据接收线程
threading.Thread(target=fetch_network_data, daemon=True).start()

# 创建动画
ani = FuncAnimation(fig, update, interval=100)  # 每100ms更新一次
plt.show()

关键注意事项 #

• 线程安全：多线程操作数据时必须用queue或lock保证数据访问安全，避免竞态条件。
• 交互式模式：plt.ion()开启非阻塞绘图，配合plt.draw()和plt.pause()实现实时更新。
• 轴范围调整：若数据超出初始轴范围，需动态修改轴限制，避免绘制内容被截断。

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