連載 [第4回] :

2019年2月1日(金)

本連載の第1回ではデータ連携の必要性を紹介し、その中で連携の手段について紹介しました。手段を切り分けしたものが図1（再掲）になりますが、既存のシステムのまま連携するパターン（連携型）、PostgreSQLにデータを移行するパターン（移行型）のそれぞれのパターンについて、実機評価を行います。その結果から、業務的に利用できる場面や利用するにあたっての注意点を洗い出したいと思います。

図1：システム連携の手段

評価環境

評価内容を説明する前に、評価環境を説明します。今回の評価で使用した物理環境を図2に示します。PostgreSQLサーバ、HiveServer、Hadoopのマスタノードを1台で構成し、 Hadoopのワーカノードは3台構成としました。

図2：物理環境構成

次に論理環境を図3に示します。

図3：論理環境構成

バッチPGは、業務アプリ側（PostgreSQL）で「見える化」するためのETL（データ取得、変換／加工、ロード）を行うプログラムになります。その他、評価で使用したソフトウェアとそのバージョンを表10に示します。

表10：ソフトウェア構成

ソフトウェア	バージョン
OS	RedHat Enterprise Linux 6.7 (x86_64)
PostgreSQL	PostgreSQL 10.0 hdfs_fdw 2.0.2
Hadoop	CDH 5.11.1

PostgreSQLの設定を表11に示します。

表11：postgresql.conf設定

パラメータ	設定値
shared_buffers	8GB
maintenance_work_mem	2GB
wal_level	replica
checkpoint_timeout	30min
checkpoint_completion_target	0.9
archive_mode	on
max_wal_senders	2
hot_standby	on
effective_cache_size	16GB
logging_collector	on
Autovacuum	on
hdfs_fdw.jvmpath	‘/usr/lib/jvm/java-1.8.0-openjdk-1.8.0.171-8.b10.el7_5.x86_64/jre/lib/amd64/server’
hdfs_fdw.classpath	‘/usr/local/pgsql/lib/HiveJdbcClient-1.0.jar:/opt/cloudera/parcels/CDH-5.14.2-1.cdh5.14.2.p0.3/jars/hadoop-common-2.6.0-cdh5.14.2.jar:/opt/cloudera/parcels/CDH-5.14.2-1.cdh5.14.2.p0.3/jars/hive-jdbc-1.1.0-cdh5.14.2-standalone.jar’

ここまでが、評価環境の概要になります。

連携型の評価概要

それでは、まず連携型の評価を行います。既存システムを活かしたまま連携するに当たっては、次のパターンで比較評価します。

FDWを使って見える化用データを作成するパターン（以下、「FDW連携」と表記）
アプリで各々のデータにアクセスし見える化用データを作成するパターン（以下、「アプリ連携」と表記）

まず、FDW連携のイメージを図4、テーブル関連図を図5に示します。

図4：FDW連携した場合のイメージ図

図5：FDW連携のテーブル関連図

予め、集計結果テーブル（meter_analyzeテーブル）用の外部テーブル（meter_analyze_fdw）を作成し、外部データとしてアクセスできるようにします。このFDWテーブルと対応データ（metersテーブル）を組み合わせて、見える化データ（supportテーブル）を生成します。

この構築した環境で、外部テーブルにアクセスした際のhdfs_fdwの実行計画を確認してみたいと思います。

1hdfsfdw=# explain analyze select count(*) from meter_analyze_fdw where year_month = '201701';
2                                       QUERY PLAN
3------------------------------------------------------------------------------------------
4Aggregate  (cost=1100002.50..1100002.51 rows=1 width=8) (actual time=39792.123..39792.124
5 rows=1 loops=1)
6 ->  Foreign Scan on meter_analyze_fdw (cost=100000.00..1100000.00 rows=1000 width=0) (actual time=306.846..38433.607 rows=4800000 loops=1)
7 Planning time: 112.417 ms
8 Execution time: 40187.927 ms
9(4 rows)

図6：実行計画

このように、Foreign Scanとなっていて、外部データを参照していることが確認できます。次に、Hive側のログを確認してみたいと思います。

1Compiling command(queryId=hive_id): SELECT * FROM default.meter_analyze WHERE ((year_month = '201701'))
2Executing command(queryId=hive_id): SELECT * FROM default.meter_analyze WHERE ((year_month = '201701'))
3ORC pushdown predicate: leaf-0 = (EQUALS year_month 201701)
4Reading ORC rows from hdfs://pgmaster:8020/user/hive/warehouse/meter_analyze/year_month=201701/000000_0 with {include: [true, true, true, true, true], offset: 0, length: 9223372036854775807, sarg: leaf-0 = (EQUALS year_month 201701)
5expr = leaf-0, columns: ['null', 'meter_id', 'is_holiday', 'hour', 'usage']}

図7：Hiveログ（対象箇所のみ抜粋）

Hive側のデータは月単位で作成しており、対象ファイルのみアクセス（pushdown）することでI/O削減による高速化ができていることがわかります。

なお、既存システムを活かしたまま連携する、と記載しましたが、今回生データが入っているHiveテーブル（meter_dataテーブル）に直接アクセスして取得するのではなく、分析結果用Hiveテーブル（meter_analyzeテーブル）を予め作成して取得しないといけなくなりました。この点は重要ですので、ここで補足いたします。

わざわざ分析結果用のデータを予め作成する必要があるのは、生データをPostgreSQLでETL処理を行おうとすると、データの取得サイズが巨大になり、メモリを消費し尽くしてしまい、OOM Killerが発生してしまったためです。その対策として、Hadoop側で出来る範囲でETL処理を行った結果（分析結果）データを持っておくという対応が必要でした。この点は、利用にあたって、注意が必要な点かと思います。なお前章で、「リモート側で結合やソート、集約関数等のpushdown対応」をやってほしい理由は、このためになります。

次に、アプリ連携のイメージを図8、テーブル関連図を図9に示します。

図8：アプリ連携した場合のイメージ図

図9：アプリ連携のテーブル関連図

アプリ連携では、集計結果テーブル（meter_analyzeテーブル）と対応データ（metersテーブル）をアクセスし、アプリ側で組み合わせて、見える化データ（supportテーブル）を生成します。

以上が、評価の概要になります。次に、評価項目を説明します。

評価項目

評価項目は、次の3点について評価していきます。

評価1：設計・開発、運用・保守、業務変化への対応について、連携方式ごとに机上評価
評価2：開発コストの比較（見える化テーブルの生成）
評価3：性能面の比較

それでは、さっそく評価結果を説明します。

評価結果

評価結果1

設計・開発、運用・保守、業務変化への対応について、机上評価を行った結果を表12に示します。

表12：システム設計・運用各フェーズでの各連携方式の比較評価（机上評価）

フェーズ	FDW連携	アプリ連携
設計・開発	開発コストが少ない FDWツールの選定や構築コストがかかる	やりたいことを細かいレベルで実現しやすい開発コスト、テストコストが大きくなる傾向（アプリで連携やSQLでできるような結合処理の実装が必要）
運用・保守	活発な開発コミュニティであれば品質向上が図れる一方で、活発でないと開発停止になるリスクがある障害時の切り分けコストが大きい（DBAとの連携が必要）	障害発生時の切り分けが容易、内部だけで対応可能 RDBやHadoopの接続はトラブルに陥りやすく、保守改修コストが大きい
業務変化への対応	追加、変更などの対応が容易（SQLの修正のみ…等） FDWとしての制約がある（今回の場合は、HadoopアクセスにはHiveが必要）	柔軟な対応が可能小さな変更レベルでもアプリの改修が必要となるため、コストがかかる

このように、どのフェーズにおいても、各連携方式でメリット・デメリットが存在します。したがって、デメリットが許容できる連携方式を選択する必要があります。

評価結果2

次に、開発コストの比較をします。見える化テーブルを生成するに当たっての開発量を比較してみます。

FDW連携

FDW連携は非常に単純です（図10）。PostgreSQLにアクセスすることで、裏でHadoop側のデータを取得し、業務データとマージした結果を格納できます。

図10：FDW連携の場合のデータ生成フロー

この処理のソースを図11に示します。下記以外にMeterObjectのデータクラスを作成していますが、そちらのソースは割愛します。

01import java.sql.*;
02import java.util.ArrayList;
03 
04class MierukaUseFdw {
05 
06 public static void main (int year_month) {
07 
08 // classロード
09 try {
10 Class.forName("org.postgresql.Driver");
11 } catch (ClassNotFoundException e) {
12 System.err.println("Class Not Found.");
13 e.printStackTrace();
14 System.exit(1);
15 }
16 
17 // データベース接続
18 Connection con = null;
19 try {
20 con = DriverManager.getConnection("jdbc:postgresql://192.168.1.1:5432/postgres", "postgres", "postgres");
21 } catch (SQLException e) {
22 System.err.println("Connection Error.");
23 e.printStackTrace();
24 System.exit(1);
25 }
26 
27 // SQL実行
28 PreparedStatement pstmt = null;
29 ResultSet res = null;
30 ArrayList<MeterObject> meterMap = new ArrayList<MeterObject>();
31 MeterObject currentMeter = null;
32 try {
33 // データ取得
34 pstmt = con.prepareStatement("select b.fact_id, a.meter_id, a.month, a.is_holiday, a.hour, a.usage from meter_analyze_fdw a, meters b where ((a.meter_id = b.id) and (a.year_month = ?))");
35 pstmt.setInt(1, year_month);
36 res = pstmt.executeQuery();
37 
38 while (res.next()) {
39 currentMeter = new MeterObject(Integer.valueOf(res.getString(1)),
40 Integer.valueOf(res.getString(2)),
41 Integer.valueOf(res.getString(3)),
42 Boolean.valueOf(res.getBoolean(4)),
43 Integer.valueOf(res.getString(5)),
44 Double.valueOf(res.getString(6)));
45 meterMap.add(currentMeter);
46 }
47 res.close();
48 
49 // データ格納
50 con.setAutoCommit(false);
51 pstmt = con.prepareStatement("insert into support values (?, ?, ?, ?, ?, ?);");
52 for(MeterObject meter:meterMap){
53 pstmt.setInt(1, meter.getFact_id());
54 pstmt.setInt(2, meter.getMeter_id());
55 pstmt.setInt(3, meter.getYear_month());
56 pstmt.setBoolean(4, meter.getIs_holiday());
57 pstmt.setInt(5, meter.getHour());
58 pstmt.setDouble(6, meter.getUsage());
59 pstmt.addBatch();
60 }
61 pstmt.executeBatch();
62 con.commit();
63 
64 } catch (SQLException e) {
65 System.err.println("Execute Error.");
66 e.printStackTrace();
67 System.exit(1);
68 
69 } finally {
70 if (pstmt != null) {
71 try {
72 pstmt.close();
73 } catch (SQLException e) {
74 e.printStackTrace();
75 }
76 }
77 if (con != null) {
78 try {
79 con.close();
80 } catch (SQLException e) {
81 e.printStackTrace();
82 }
83 }
84 }
85 }
86}

図11：FDW連携（MierukaUseFdw.java）ソース

アプリ連携

アプリ連携の場合は、アプリ側でIoTデータと業務データにそれぞれ接続、取得し、さらにマージしてから格納する必要があります（図12）。

図12：アプリ連携の場合のデータ生成フロー

この処理のソースを図13に示します。先ほどと同様に、MeterObjectのデータクラスの説明は割愛します。

001import java.sql.*;
002import java.util.ArrayList;
003import java.util.HashMap;
004import java.util.Map;
005 
006class MierukaUseHive {
007 
008 public static void main (int year_month) {
009 
010 /* hive */
011 // classロード
012 try {
013 Class.forName("org.apache.hive.jdbc.HiveDriver");
014 } catch (ClassNotFoundException e) {
015 System.err.println("Class Not Found.");
016 e.printStackTrace();
017 System.exit(1);
018 }
019 
020 // Hive接続
021 Connection con = null;
022 try {
023 con = DriverManager.getConnection("jdbc:hive2://192.168.1.101:10000/default", "", "");
024 } catch (SQLException e) {
025 System.err.println("Connection Error.");
026 e.printStackTrace();
027 System.exit(1);
028 }
029 
030 // SQL実行
031 PreparedStatement pstmt = null;
032 ResultSet res = null;
033 HashMap<Integer,Integer> meter2factMap = new HashMap<Integer,Integer>();
034 ArrayList<MeterObject> meterMap = new ArrayList<MeterObject>();
035 MeterObject currentMeter = null;
036 try {
037 // データ取得(IoT分析データ)
038 pstmt = con.prepareStatement("select * from meter_analyze where year_month = ?");
039 pstmt.setInt(1, year_month);
040 res = pstmt.executeQuery();
041 
042 while (res.next()) {
043 currentMeter = new MeterObject(Integer.valueOf(res.getString(1)),
044 Integer.valueOf(res.getString(2)),
045 Boolean.valueOf(res.getBoolean(3)),
046 Integer.valueOf(res.getString(4)),
047 Double.valueOf(res.getString(5)));
048 meterMap.add(currentMeter);
049 }
050 res.close();
051 
052 } catch (SQLException e) {
053 System.err.println("Execute Error.");
054 e.printStackTrace();
055 System.exit(1);
056 
057 } finally {
058 if (pstmt != null) {
059 try {
060 pstmt.close();
061 } catch (SQLException e) {
062 e.printStackTrace();
063 }
064 }
065 if (con != null) {
066 try {
067 con.close();
068 } catch (SQLException e) {
069 e.printStackTrace();
070 }
071 }
072 }
073 
074 /* postgres */
075 // classロード
076 try {
077 Class.forName("org.postgresql.Driver");
078 } catch (ClassNotFoundException e) {
079 System.err.println("Class Not Found.");
080 e.printStackTrace();
081 System.exit(1);
082 }
083 
084 // データベース接続
085 try {
086 con = DriverManager.getConnection("jdbc:postgresql://192.168.1.1:5432/postgres", "postgres", "postgres");
087 } catch (SQLException e) {
088 System.err.println("Connection Error.");
089 e.printStackTrace();
090 System.exit(1);
091 }
092 
093 // SQL実行
094 try {
095 // データ取得(業務データ)
096 pstmt = con.prepareStatement("select * from meters");
097 res = pstmt.executeQuery();
098 
099 while (res.next()) {
100 meter2factMap.put(Integer.valueOf(res.getString(1)), Integer.valueOf(res.getString(2)));
101 }
102 res.close();
103 
104 // データ処理＆格納
105 con.setAutoCommit(false);
106 pstmt = con.prepareStatement("insert into support values (?, ?, ?, ?, ?, ?);");
107 for(MeterObject meter:meterMap){
108 pstmt.setInt(1, meter2factMap.get(meter.getMeter_id()));
109 pstmt.setInt(2, meter.getMeter_id());
110 pstmt.setInt(3, meter.getYear_month());
111 pstmt.setBoolean(4, meter.getIs_holiday());
112 pstmt.setInt(5, meter.getHour());
113 pstmt.setDouble(6, meter.getUsage());
114 pstmt.addBatch();
115 }
116 pstmt.executeBatch();
117 con.commit();
118 
119 } catch (SQLException e) {
120 System.err.println("Execute Error.");
121 e.printStackTrace();
122 System.exit(1);
123 
124 } finally {
125 if (pstmt != null) {
126 try {
127 pstmt.close();
128 } catch (SQLException e) {
129 e.printStackTrace();
130 }
131 }
132 if (con != null) {
133 try {
134 con.close();
135 } catch (SQLException e) {
136 e.printStackTrace();
137 }
138 }
139 }
140 }
141}

図13：アプリ連携（MierukaUseHive.java）のソース

今回の例では、「結合・演算処理」部分が単純なジョインのみだったので開発工数は少ないですが、それでもそれぞれ接続、取得処理を行わないといけないため開発工数はほぼ倍になりました。実際には、もっと複雑なSQLを演算処理する必要になると思いますし、開発工数が膨れ上がるにつれ、その分テストも行う必要が出てくるので、その点を考えただけでもSQLで処理ができるFDW連携の優位性が感じられるのではないかと思います。

評価結果3

3つ目に、性能面の比較をしたいと思います。性能面の比較については、見える化テーブルの作成時間と、作成処理にかかるシステム影響を見てみたいと思います。

まず、見える化テーブルの作成時間の比較結果を図14に示します。HiveからデータをエクスポートしてPostgreSQLにデータをロードするといった従来の方法も併せて比較しました（「ファイル連携」と表記）。

なお、Hadoop、PostgreSQLのキャッシュによる影響が出ないように初期化を行ってから、測定しています。

図14：「見える化テーブル」の作成時間比較

次にシステムへの影響を見てみます。CPUとメモリの負荷影響を実機検証しましたが、メモリの負荷については連携方式による差は見られませんでした。そのため、CPUの負荷について、それぞれの連携方法についての比較結果を図15に示します。

図15：「見える化テーブル」のCPU負荷

図15で示したように、アプリ連携に比べ、FDW連携はCPU利用率が高騰する頻度が高く、特に、IoTデータ取得時に高くなる傾向になりました。業務影響がでるかといった事前の負荷検証は実施すると思いますので、もし性能が課題になりそうであれば、スケールアップ等を検討してください。

移行型の評価概要

次に、移行型の評価を行います。シナリオは、IoTシステムを業務システム側に統合する当たって、Hadoopに格納されているIoTデータをPostgreSQLに移行する必要があります。そのデータ移行について、次のパターンで比較評価します。

FDWを使って移行するパターン（以下、「FDW移行」と表記）
手動で移行するパターン（以下、「手動移行」と表記）

次に、FDW移行のイメージを図16、テーブル関連図を図17に示します。

図16：FDW移行のイメージ図

図17：FDW移行のテーブル関連図

次に、手動のイメージを図18、テーブル関連図を図19に示します。

図18：手動移行のイメージ図

図19：手動移行のテーブル関連図

以上が、評価の概要になります。次に、評価項目を説明します。

評価項目

評価項目は、FDW移行（2種類）と手動移行の計3種類の方法で、データ移行時間を評価していきたいと思います。

FDW移行
1. SQL(INSERT-SELECT文)で直接移行する
2. SQL(COPY文)で一度ファイルに出力し、そのファイルを使って移行する
手動移行

評価結果

データ移行時間の比較結果を図20に示します。なお、FDW移行については、連携型の時と同様に、全データを一度に移行しようとすると、データの取得サイズが巨大になるため、OOM Killerが発生してしまいます。そのため、移行できるサイズに分割して、移行した結果（総計）となっています。

図20：データ移行時間

今回の結果では、FDW移行に比べ、手動移行の方が圧倒的に高速に移行できました。業務的に移行を考えた場合、短時間での移行が望まれるため、FDWを利用するより手動で移行することが望まれると思います。このように、何でもFDWを利用する、というわけではなく、きちんと実機調査して利用するようにしてください。

おわりに

以上が、hdfs_fdwを実機検証した結果となります。

近年は、データの量や種類が膨大になる中で、様々なデータを組み合わせて付加価値のある情報を得ようとします。そのため、システム連携は避けられないものであり、PostgreSQLのFDWは非常に便利なツールで、今回の検証結果から、hdfs_fdwは、HadoopとPostgreSQLを連携した開発や運用を容易にできるという点で有効性が確認できたと思います。

ただ、どのツールでもそうですが、設計・開発や運用面、性能面等へのメリット・デメリットがあり、利用するに当たっては業務システムに合うか検証してから適用する必要があります（特に、今回の検証結果では性能面が懸念になりそうであり、実機検証は必須です）。

なお、hdfs_fdwについては、まだ開発途上であり機能拡張を通じて使いやすくなると思いますので、引き続きウォッチしていこうと思います。

以上で、今回の連載を終了します。本連載がPostgreSQLを活用する上でのFDWの有用性や設計・開発の参考になれば幸いです。

著者

稲垣毅

この著者の記事一覧この著者の
記事一覧

株式会社日立製作所

2011年頃から、基幹系でのOSS利活用のためopensource COBOLやPostgreSQLの研究開発や技術支援に従事してきた。2018年から現職となり、PostgreSQL、MySQLのソリューション開発やサポートを担当している。また、PostgreSQLエンタープライズ・コンソーシアム（PGECons）に参画し、PostgreSQLの検証活動や広報活動を行い、PostgreSQLの普及発展に努めている。