24 lines
819 B
Plaintext
24 lines
819 B
Plaintext
ns = params_kw.copy()
|
|
|
|
sql1 = """select sum(input_tokens + output_tokens) as tokens, modelinstanceid, modeltypeid, transdate
|
|
from feelog
|
|
where pricing_mode = 'token'
|
|
and transdate >= ${start_date}$
|
|
and transdate < ${end_date}$
|
|
group by transdate, modelinstanceid, modeltypeid"""
|
|
|
|
sql = f"""select a.*, b.name as miname, c.name as modeltypename, concat(b.name, '(', c.name , ')') as name
|
|
from ({sql1}) 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"""
|
|
info(f'{sql=}, {ns=}')
|
|
db = DBPools()
|
|
async with db.sqlorContext('sage') as sor:
|
|
r = await sor.sqlExe(sql, ns.copy())
|
|
info(f"daily_total_usage.dspy:{ns=}, return {r=}")
|
|
return r
|
|
exception(f"daily_total_usage.dspy:{sql=}, {ns=}, exception happend")
|
|
return []
|