(PostgreSQLは手元にないので) 別の SQL (DuckDB)使う方法
DBのインポート・エクスポートに, (簡単のため) pandasを使用
(SQLのみでも使用可能)
- 一旦 月ごとに集計して
- 「0004 の場合 12 で割る」ための, 歯抜けの場所をゼロ埋め
update
ゼロ埋め参考: ja.stackoverflow.com sqlで欠損日付のレコードを補完したい
colabで動作確認
import duckdb
import pandas as pd
import io
f = io.StringIO('''
date id amount
2023-11-01 0001 2500
2023-11-10 0001 10000
2023-11-29 0001 3800
2023-12-15 0001 3000
2023-11-01 0002 8000
2023-11-05 0003 5500
2023-11-22 0003 8000
2023-12-05 0003 5500
2023-12-23 0003 8000
2024-02-20 0004 9000
''')
df = pd.read_csv(f, sep='\t', dtype={'id': 'unicode', 'amount': int}, parse_dates=['date'])
ndf = duckdb.sql("""
create view if not exists myview(ym, id, amount) as
select t2.ym, t1.id, coalesce(t3.sum_amo, 0)
from (select distinct id from df) as t1
cross join (select unnest(generate_series(start, stop, interval 1 month)) as ym
from (select min(date_trunc('month', date))as start, max(date_trunc('month', date))as stop from df)) as t2
left join (SELECT date_trunc('month', date) as ym, id, sum(amount) as sum_amo FROM df GROUP BY ym,id) as t3
on t1.id = t3.id and t2.ym = t3.ym;
select * from myview;
""").df()
print(ndf)
# ym id amount
# 0 2023-11-01 0002 8000.0
# 1 2023-12-01 0002 0.0
# 2 2024-01-01 0002 0.0
# 3 2024-02-01 0002 0.0
# 4 2023-11-01 0003 13500.0
# 5 2023-12-01 0003 13500.0
# 6 2024-01-01 0003 0.0
# 7 2024-02-01 0003 0.0
# 8 2023-11-01 0001 16300.0
# 9 2023-12-01 0001 3000.0
# 10 2024-01-01 0001 0.0
# 11 2024-02-01 0001 0.0
# 12 2024-02-01 0004 9000.0
# 13 2023-11-01 0004 0.0
# 14 2023-12-01 0004 0.0
# 15 2024-01-01 0004 0.0
先のデータを用いて平均算出
(SQLの違い: 日付計算に関して SQLによって違いがあるかもしれません)
duckdb.sql("""
SELECT ym, COUNT(*)
FROM (
SELECT
strftime(ym, '%Y-%m') as ym,
"id",
AVG("amount") OVER (
PARTITION BY "id"
ORDER BY "ym" ASC
RANGE BETWEEN INTERVAL 12 MONTH PRECEDING
AND INTERVAL 0 DAYS FOLLOWING) asum,
FROM ndf
)
WHERE asum > 10000
GROUP BY ym
""")
┌─────────┬──────────────┐
│ ym │ count_star() │
│ varchar │ int64 │
├─────────┼──────────────┤
│ 2023-11 │ 2 │
│ 2023-12 │ 1 │
└─────────┴──────────────┘
この回答では SQL文は 2つに分かれてるけど, sub query使うなどして合成すれば, 一つにまとめることも可能