主な内容は以下の通りです:

  • パフォーマンスの最適化: 膨大なレコードを処理する際、メモリ使用量を抑えつつ高速にフィルタリングを行うための条件設定やアルゴリズムの考え方。
  • 効率的なクエリ・条件指定: 不要なスキャンを防ぎ、必要なデータだけを正確に抽出するためのフィルタリング構文やパラメータの指定方法。
  • 実用的なコード例: 実際のシステムやデータベース連携において、どのようにフィルタリング処理を実装すべきかのサンプルコードの提示。

🧩 ビッグデータをフィルタリング

df_a は数万件以上の行数と100を超える列を持つ大規模なデータフレームであり、その中から特定の name に一致するデータのみを抽出したい場合がある。 このとき、抽出対象となる name の一覧が df_b の name 列に格納されている場合、Pandas の isin() メソッドを利用することで効率的に絞り込みを行うことができる。

🌱 isin()メソッドとは

isin() は、指定した値の集合に各要素が含まれているかを判定し、真偽値(True / False)を返すメソッドである。

df_a['name'] の値が df_b['name'] に含まれている行のみを残す場合:
→ df_a['name'].isin(df_b['name']) を条件として使用する。

🔍 一致するものを残す

1
df_a_filtered_isn = df_a[df_a['name'].isin(df_b['name'])]

この処理により、df_b に登録されている約100件の name と一致する行だけが df_a から抽出される。df_a の行数や列数が多い場合でも、isin() はベクトル化された処理として実行されるため、Python の for ループで1件ずつ比較する方法よりも高速かつ簡潔に実装できる。

🔍 逆方向にフィルタリングする(一致しないものを残す)

df_b の name 列に登録されている値を除外条件とし、df_a の name 列が df_b に存在しないレコードのみを抽出する。 実装には Pandas の isin() メソッドと否定演算子 「~」 を使用する。

1
df_a_filtered_notin = df_a[~df_a['name'].isin(df_b['name'])]

📋 元データ df_a

No	name	score
1	A	    80
2	B	    90
3	C	    75
4	D	    88
5	E	    92

📋 元データ df_b

name
A
D
E

① isin() による判定

1
df_a['name'].isin(df_b['name'])

❶ df_a[‘name’] の各値について、「df_b[‘name’] に存在するか?」を確認します。
❷ df_a[‘name’] df_b に存在するか

A	False
B	True
C	False
D	True
E	True

結果は以下のような Boolean 型の Series になります。

0    False
1     True
2    False
3     True
4     True
dtype: bool

② True の行だけを抽出

1
2
3
df_a[
    df_a['name'].isin(df_b['name'])
]

実際には次のようなイメージです。

          条件
行1 A  → False ✕
行2 B  → True  ○
行3 C  → False ✕
行4 D  → True  ○
行5 E  → True  ○

③ 抽出結果

1
df_a_filtered
No	name	score
2	B	    90
4	D	    88
5	E	    92

🚀 SQL と比較する

1
df_a_filtered = df_a[~df_a['name'].isin(df_b['name'])]

これは SQL の次の条件とほぼ同じ意味です。

1
WHERE name NOT IN (...)

🧠 フィルタされた数だけを知りたい

  • len() を使う(シンプル)ですが、shape を使うのが、おすすめです。
  • df.shape は (行数, 列数) のタプルを返します。例えば df.shapeが (100, 5) なら、100行5列です。
  • 実務では df.shape[0] を使うことが多いです。列数も同時に確認したい場合は、以下のとおりです。
1
2
print(f"行数: {df.shape[0]}")
print(f"列数: {df.shape[1]}")

len() を使いたいのであれば

1
2
print(len(df))       
print(len(df.index)) 

※このブログの流れであれば、dfは、df_a_filtered_isnもしくは、df_a_filtered_notinで読み返してください。

🚀 複合キーでフィルタリングする(複数列で一致判定したい場合)

実務では、1列だけで一致判定するケースは少なく、 複数列の組み合わせ(複合キー)で一致を判定したい場面が多くあります。

例えば、以下のようなケースです:

- 顧客ID + 日付  
- 商品コード + サイズ  
- 銘柄コード + 市場区分  
- 氏名 + 生年月日  

こうした場合、isin()1列に対してしか使えないため、 複数列をまとめて「キー列」を作る必要があります。

🔁 方法:複数列を結合してキーを作る

1
2
3
4
5
6
# df_a と df_b の複合キーを作成
df_a['key'] = df_a['col1'].astype(str) + '_' + df_a['col2'].astype(str)
df_b['key'] = df_b['col1'].astype(str) + '_' + df_b['col2'].astype(str)

# 複合キーで一致する行だけを抽出(IN)
df_filtered = df_a[df_a['key'].isin(df_b['key'])]

NOT IN(複合キーで一致しない行を抽出)

1
df_filtered_notin = df_a[~df_a['key'].isin(df_b['key'])]

🎯 注意点

1. データ型を揃える

  • astype(str) を使って文字列化しておくと安全です。

2. 区切り文字を入れる

  • col1 + col2 だと区別できないケースがある。
  • col1 + '_' + col2 のように区切り文字を入れるのがポイントです。

3. merge のほうが適切な場合もある

複合キーが増えるほど merge のほうが安全で高速になるケースもあります。