ns = params_kw.copy()

sql="""select a.*, b.name as miname, c.name as modeltypename, concat(b.name, '(', c.name , ')') as name
from ( 
select sum(input_tokens + output_tokens) as tokens, modelinstanceid, modeltypeid
   from feelog 
   where pricing_mode = 'token' 
       and transdate >= ${start_date}$
       and transdate < ${end_date}$
   group by modelinstanceid, modeltypeid
) a 
    left join modelinstance b on a.modelinstanceid=b.id
    left join modeltype c on a.modeltypeid = c.id
where tokens > 10000
order by a.tokens desc
"""

db = DBPools()
async with db.sqlorContext('sage') as sor:
	r = await sor.sqlExe(sql, ns.copy())
	info(f"total_usage.dspy:{ns=}, return {r=}")
	return r
exception(f"total_usage.dspy:{sql=}, {ns=}, exception happend")
return []