关闭Cassandra集群和Session时触发Asyncore事件循环异常求助

碰到过好多次类似的Cassandra驱动关闭时的异常，结合你的环境和代码，给你梳理下问题和可行的解决办法：

你的环境信息 #

• Cassandra/DSE版本：Cassandra 2.1.15.1403 | DSE 4.8.9
• 测试过的Python驱动版本：2.1.2、3.1.7

问题场景 #

你用Python脚本迁移某张表的数据，完成后用这段代码关闭连接：

if (None != self.session): self.session.shutdown()
if (None != self.cluster): self.cluster.shutdown()

结果执行cluster.shutdown()时抛出了异常：

DEBUG: Closed socket to 127.0.0.1
DEBUG: Asyncore event loop stopped unexepectedly
Traceback (most recent call last):
File "/usr/local/lib..."

问题原因&解决思路 #

这个异常本质是驱动的异步事件循环在关闭时被意外终止，大概率是session和cluster的关闭时机没配合好，或者驱动内部的资源释放有延迟。这里给你几个实用的解决方向：

1. 给session shutdown加个短暂等待 #

有时候session的shutdown看起来执行完了，但底层的socket连接还没完全释放，这时候立刻关cluster就会触发异常。可以加个短时间的等待，确保session资源完全释放：

if self.session is not None:
    self.session.shutdown()
    # 给1秒时间让session彻底释放资源，时间可以根据实际情况调整
    import time
    time.sleep(1)
if self.cluster is not None:
    self.cluster.shutdown()

2. 用3.x驱动的wait_for_closed()方法（针对3.1.7版本） #

如果你用的是3.1.7版本的驱动，Cluster对象提供了wait_for_closed()方法，能确保cluster完全关闭后再继续，避免事件循环异常：

if self.session is not None:
    self.session.shutdown()
if self.cluster is not None:
    self.cluster.shutdown()
    # 等待cluster彻底关闭
    self.cluster.wait_for_closed()

3. 捕获异常忽略（临时应急方案） #

如果上面的方法都没效果，而且这个异常不影响你的数据迁移结果（毕竟数据已经迁移完成了），可以临时捕获这个异常，不让脚本崩溃：

try:
    if self.session is not None:
        self.session.shutdown()
    if self.cluster is not None:
        self.cluster.shutdown()
except Exception as e:
    # 只打个日志提醒，不中断脚本
    print(f"关闭连接时出现警告: {str(e)}")

4. 检查脚本里的其他异步操作 #

如果你的脚本里还有其他异步逻辑（比如混用了asyncio或者驱动的异步API），一定要确保所有异步任务都已经执行完成，再去关闭session和cluster——未完成的异步任务会干扰驱动的事件循环，导致shutdown异常。

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