Tool_Agent/manual_sync.py

import asyncio
import logging

# 配置日志以便看到同步过程的详情
logging.basicConfig(level=logging.INFO, format="%(asctime)s [%(levelname)s] %(message)s")

from tool_agent.router.agent import Router

async def main():
    print("="*50)
    print(" 开始全量同步 Registry 本地工具 -> PostgreSQL ...")
    print("="*50)
    
    agent = Router()
    await agent._sync_knowhub_after_register()
    
    print("="*50)
    print(" 同步执行完毕！赶快去 Dashboard 看看效果吧！")
    print("="*50)

if __name__ == '__main__':
    asyncio.run(main())