回答編集履歴
2
INSERT SELECT で一括処理する場合の性能の参考URLを追加
test
CHANGED
|
@@ -27,6 +27,8 @@
|
|
|
27
27
|
|
|
28
28
|
|
|
29
29
|
というのがあります。つまり、COPY とか INSERT SELECT は普通の INSERT 文を実行するより数倍早いはずです。正確な数値で示すことができませんが、[大量データ取込のいろいろ PostgreSQL編](http://www.techscore.com/blog/2012/12/14/%E5%A4%A7%E9%87%8F%E3%83%87%E3%83%BC%E3%82%BF%E5%8F%96%E8%BE%BC%E3%81%AE%E3%81%84%E3%82%8D%E3%81%84%E3%82%8D-postgresql%E7%B7%A8/)によると、数十倍の差があります。
|
|
30
|
+
|
|
31
|
+
複数回 INSERT VS INSERT SELECT のほうは、ちょうどいいのがぱっと見つけられなかったのですが、[カーソルのループでINSERT100万とSELECT INSERT100万の速度比較してみた](http://kagamihoge.hatenablog.com/entry/20120603/1338727402)に ORACLE で10倍以上差がついている記事がありました。
|
|
30
32
|
|
|
31
33
|
|
|
32
34
|
|
1
説明を詳細化し、テーブルを2個に分ける理由の説明を追加しました
test
CHANGED
|
@@ -16,21 +16,43 @@
|
|
|
16
16
|
|
|
17
17
|
とおっしゃってますが、実装されようとしているアプリの性能要件から、 COPY でのインポートが必須であると思われます。
|
|
18
18
|
|
|
19
|
-
それで、生データのテーブルと完成テーブルを分けてはどうでしょうか。
|
|
19
|
+
それで、生データのテーブルと完成テーブルを分けてはどうでしょうか。分ける前提として、
|
|
20
20
|
|
|
21
21
|
|
|
22
22
|
|
|
23
|
-
-
|
|
23
|
+
- PostgreSQL はデータを一括して処理するほうが1件ずつ処理するより数倍早い
|
|
24
24
|
|
|
25
|
-
-
|
|
25
|
+
- 一括処理する塊は大きければ大きいほど有利である
|
|
26
26
|
|
|
27
|
-
- 生データテーブルにはインデックスをはらない（インポートの高速化のため）
|
|
28
27
|
|
|
29
|
-
- 一定時間ごとのバッチ処理で生データテーブルの内容から完成形テーブルに INSERT 文で転記する（WHERE や JOIN のロジックはこの転記時に実行する:参考 [表をSELECTして別の表へINSERTする](http://www.projectgroup.info/tips/SQLServer/SQL/SQL000004.html)：今回の質問の2.に近い)
|
|
30
28
|
|
|
31
|
-
|
|
29
|
+
というのがあります。つまり、COPY とか INSERT SELECT は普通の INSERT 文を実行するより数倍早いはずです。正確な数値で示すことができませんが、[大量データ取込のいろいろ PostgreSQL編](http://www.techscore.com/blog/2012/12/14/%E5%A4%A7%E9%87%8F%E3%83%87%E3%83%BC%E3%82%BF%E5%8F%96%E8%BE%BC%E3%81%AE%E3%81%84%E3%82%8D%E3%81%84%E3%82%8D-postgresql%E7%B7%A8/)によると、数十倍の差があります。
|
|
32
30
|
|
|
31
|
+
|
|
32
|
+
|
|
33
|
+
具体的には、テーブルへの登録処理を2段のパイプラインに分けます。1段目の処理でデータを加工処理せずに受信したままの形でデータベースに登録します。この登録処理では速度を最大にするために TSV ファイル形式からのCOPY命令を利用します。今回の質問の 1. の考え方に近いです。
|
|
34
|
+
|
|
35
|
+
|
|
36
|
+
|
|
37
|
+
0. データを受信したプログラムで TSVファイルを生成
|
|
38
|
+
|
|
39
|
+
0. 生成したファイルから COPY で生データテーブルにインポートする
|
|
40
|
+
|
|
41
|
+
|
|
42
|
+
|
|
43
|
+
このとき、後の処理のために生データテーブルには[シリアルデータ型](https://www.postgresql.jp/document/7.3/user/datatype.html#DATATYPE-SERIAL)で通番をふっておきます。また、インポートを高速化するため、生データテーブルにはインデックスをはらないほうが良いでしょう。
|
|
44
|
+
|
|
45
|
+
|
|
46
|
+
|
|
47
|
+
2段目の処理で、生テーブルに登録されているデータを完成形テーブルに転記します。今回の質問の2.の考え方に近いです。
|
|
48
|
+
|
|
49
|
+
|
|
50
|
+
|
|
51
|
+
0. 一定時間ごとのバッチ処理で生データテーブルの内容から完成形テーブルに INSERT 文で転記する（WHERE, JOIN,GROUP BY などの加工処理はこの転記時に実行する:参考 [表をSELECTして別の表へINSERTする](http://www.projectgroup.info/tips/SQLServer/SQL/SQL000004.html))
|
|
52
|
+
|
|
53
|
+
0. 転記時に生テーブルどこまで転記したかを別テーブルに記録しておく（前述の通番を参照）
|
|
54
|
+
|
|
33
|
-
|
|
55
|
+
0. 転記が終わった範囲のデータを生データテーブルから削除する（性能を上げるためにここを[テーブルパーティショニング](https://www.postgresql.jp/document/9.4/html/ddl-partitioning.html)を使って DELETE ではなく DROP で掃除するようにする必要があります）
|
|
34
56
|
|
|
35
57
|
|
|
36
58
|
|
|
@@ -38,7 +60,11 @@
|
|
|
38
60
|
|
|
39
61
|
|
|
40
62
|
|
|
63
|
+
この方法ですと、1段目の処理と2段めの処理は同期する必要がありませんので、以下のメリットが得られると思います。
|
|
64
|
+
|
|
41
|
-
|
|
65
|
+
- 生データテーブルの読み込みのほうはかなりの性能が出ますので、取りこぼしの心配の方がなくなる
|
|
66
|
+
|
|
67
|
+
- 完成形テーブルへの転記の INSERT 文の性能がボトルネックになってくると思いますが、受信スループットにピークがあるような場合、ピーク時に遅れが出ても後で暇になったときに追いつかせることができます（単純に一定時間ごとに一定量処理するのではなく、遅れが出ている場合は処理量が増やすようにロジックを組む必要があります）
|
|
42
68
|
|
|
43
69
|
|
|
44
70
|
|