import asyncio
from common.starrocks_connection import get_db_connection

async def main():
    sr = get_db_connection()
    q = "SELECT metadata FROM shared_source.chatbot_rsa_knowledge LIMIT 5"
    res = await sr.execute_query_async(q)
    for i, r in enumerate(res):
        print(f"METADATA {i}: {r.get('metadata')}")

asyncio.run(main())
