etcd3异步客户端应选用etcd3-grpc而非asyncio或aiohttp,因其基于grpcio+asyncio原生支持await,需pip install etcd3-grpc并配置grpc端口2379及tls证书;watch需手动重连,lease需持续await keepalive,同步与异步客户端不可混用。

etcd3 异步客户端用 asyncio 还是 aiohttp?
Python 官方 etcd3 库(etcd3)本身**不是异步的**,它底层基于 requests 同步 HTTP 客户端,直接在 async def 里调用 client.get() 会阻塞事件循环。别指望加个 await 就能跑通——它压根没实现 __aiter__ 或 async def 方法。
常见错误现象:RuntimeWarning: coroutine 'Etcd3Client.get' was never awaited,或者更隐蔽的:CPU 占用低但响应延迟高、并发请求实际串行执行。
- 真正可用的异步方案只有两个:自己用
loop.run_in_executor包一层(适合轻量过渡) - 或换用社区维护的
aioetcd(已归档)或更靠谱的etcd3-py的异步分支(注意不是 PyPI 上同名旧包) - 目前最稳的选择是
etcd3-grpc—— 它基于grpcio+asyncio,原生支持await,且兼容 etcd v3 API
etcd3-grpc 怎么装和连上服务?
etcd3-grpc 不在官方 etcd3 包里,得单独装:pip install etcd3-grpc。它依赖 grpcio,Windows 用户可能遇到编译问题,建议用预编译 wheel(如通过 conda-forge 安装)。
连接时注意:它默认走 gRPC(端口 2379),不是 HTTP(2379 是 HTTPS?错,etcd 默认 gRPC 端口就是 2379;HTTP API 是 2379 重定向或 2378,但 etcd3-grpc 只认 gRPC)。
立即学习“Python免费学习笔记(深入)”;
本文档主要讲述的是Netty 代码分析;Netty提供异步的、事件驱动的网络应用程序框架和工具,用以快速开发高性能、高可靠性的网络服务器和客户端程序;有需要的朋友可以下载看看
- 必须确认 etcd server 启用了 gRPC(
--listen-client-urls http://0.0.0.0:2379不够,要https://...或明确开启--listen-client-urls grpc://0.0.0.0:2379;不过多数新版 etcd 默认已开) - 证书配置比 HTTP 复杂:若 etcd 开了 TLS,需传
ca_cert、cert_key、cert_cert参数,不能只靠环境变量 - 示例连接:
import etcd3_grpc<br>client = etcd3_grpc.Client(host='localhost', port=2379)<br>value, meta = await client.get('/test')
watch 和 lease 操作为什么总超时或断连?
gRPC 的 watch 是长连接流式响应,但网络抖动或 etcd server GC 会导致流中断。默认情况下,etcd3-grpc 的 watch 不自动重连,也不带重试逻辑——你拿到的 WatchIterator 一旦抛出 grpc.aio.AioRpcError,就结束了。
lease 同理:lease.grant() 返回的是单次响应,续期(lease.keepalive())才是持续心跳。如果漏掉 keepalive,lease 到期后所有关联 key 立刻被删。
- watch 必须手动捕获异常并重建流,建议用
async for+try/except包裹,检测Code.UNAVAILABLE后 sleep 再重连 - lease.keepalive() 返回一个 async iterator,要持续
await anext(),否则心跳停摆;别把它当一次性方法调用 - watch 的
start_revision若设得太老,etcd 可能返回rpc error: code = OutOfRange—— 表示历史版本已被压缩,得用当前 revision 重新 watch
和同步 etcd3 混用会不会出问题?
不会直接 crash,但会破坏预期的并发模型。比如你在同一个进程里,一边用 etcd3.Client(同步)写 key,一边用 etcd3_grpc.Client(异步) watch,看起来没问题——但 watch 流的事件顺序、revision 可见性、甚至 key 的 TTL 刷新行为,在两个客户端间并不严格一致。
尤其当涉及 lease 关联操作时:同步客户端创建的 lease,异步客户端无法直接续期(lease.id 虽可传,但续期接口不互通);反之亦然。
- 一个进程内,**坚持只用一套客户端**:要么全同步,要么全异步
- 如果必须桥接(比如 legacy 代码用同步,新模块用异步),key 命名空间要隔离,避免 lease 共享、watch 范围重叠
- 调试时注意:同步客户端的
get可能读到异步客户端刚写但尚未 commit 的值(取决于 etcd raft 状态),这不是 bug,是分布式一致性模型的正常表现









