这个界面有点像 dbgate

import re
msg=b"login: Fri Sep 8 15:48:31 2023 from 127.0.0.1\r\r\n\x1b[?2004h\x1b[1;38m[v12.22.9]\x1b[0m\x1b[1;38mchaleaoch@wsl$:\x1b["
print_msg=msg.decode('utf-8')
print(print_msg)
for item in re.findall(rb'\x1b\[[0-9;]*[mK]', msg):
>>print(item.decode('utf-8')+'abc')


没问题啊，终端输出 bytes ，直接用 rb 匹配

用 mojo 还不如用 erg
https://github.com/erg-lang/erg

千兆，下载比 500M 快多了

你确定是在同一个线程里面执行的代码吗？
多线程有自己的上下文和堆栈

继续躺平，然后自己学习，这么好的坑位都不要么

我这节点挂了就直接删掉重建。。。
用 autok3s 管理的

直接用 aiostream 库

https://gist.github.com/zzl221000/6d2f586a16f058e5502907a877104f79

你需要的是 minio gateway 吧

@jacketsmith10 #3 删掉 .idea 就能解决，这个目录跨版本是不兼容的

把 .idea 删了？

真快，能说说原理吗

@zzl22100048 #10 看错了，RECONCILE_WAIT 应该是 kubernetes operator 的监控延迟，数据的延迟要另外看了

@WOSHILIDAYE #7 默认的 有个参数可以控制 Reconciliation delay

RECONCILE_WAIT 默认是 10s

可以试试 parseable https://github.com/parseablehq/parseable

是不是要类似这种效果？
让租户动态的导入依赖库

https://odh-highlander.github.io/
https://github.com/guimou/odh-highlander

@zhongjun96 山姆 59.8 16 个 1.2kg 应该比这个单价便宜吧

创建一个
sem = asyncio.Semaphore(k)

async def task():
async with sem:
....

async def main():
await asyncio.gather(*[ task() for _ in range(n) ])

asyncio.run(main())



如果更喜欢 pipeline 语法，可以用 aiostream
from aiostream import pipe, stream
async def main():
await (
stream.iterate(range(n))
| pipe.map(task,task_limit=k)
)