import sys sys.path.insert(0,'/www/server/xingyu-im/ops') from baota_publish_test_users import database,env_values,query conn,_=database(env_values()) try: rows=query(conn,"""SELECT u.id,u.public_id,p.gender,p.city_code,p.city_name FROM users u JOIN user_profiles p ON p.user_id=u.id WHERE u.is_test=1 AND u.test_batch=%s AND u.deleted_at IS NULL ORDER BY u.id""",('cn-adults-20260831-v1',)) print('count',len(rows)) print('first',rows[:12]) finally: conn.close()