PowerPoint プレゼンテーション

Size: px

Start display at page:

Download "PowerPoint プレゼンテーション"

らむみょうだに
5 years ago
Views:

2 PL/Proxy, PgBouncer とは Skype TM のバックエンドのために培われた技術将来の 10 億ユーザ認証を目標とした高可用性重視の設計を活用し軽量かつ簡単 PgBouncer はコネクションプーラー PL/Proxy はリモート DB 呼び出し用プロキシー言語でレプリケーションやパーティショニングの記述が可能コミュニティへの返礼として公開 (BSD ライセンス ) が稼動するプラットホームをサポート (Windows にも対応 ) Copyright 2009 Japan Users Group

4 運用概念図 DB1 plproxy DB2 pgbouncer pgbouncer P1 P2 P3 P4 plproxy DBx partitions WAL backups plproxy+pgbouncer を使ってみよう! オープンソースカンファレンス 2009 Okinawa ( 土 ) ( 独立行政法人情報処理推進機構 (IPA) オープンソフトウェアセンター斉藤浩 ) より引用 Copyright 2009 Japan Users Group

5 PgBouncer の特長軽量かつ強固な connection pooler 必要なメモリ量は概ね接続当たり 2kb 複数のサーバを対象全てもしくは特定のサーバに対して接続を中断可能殆どの環境設定項目をオンラインで変更可能クライアント接続の切断なくオンラインでリスタート / アップグレードが可能処理中 SQL を解析しないため CPU への負荷は小さい Copyright 2009 Japan Users Group

6 pgbouncer のモジュール構成接続管理情報認証情報 pgbouncer connect DB 1 client connect libevent イベント通知ライブラリで memcached などで使われ高速なレスポンスを実現して好評 Postgres フロントエンド / バックエンドプロトコル 3.0 を独自のハンドシェークで実装している DB 2 plproxy+pgbouncer を使ってみよう! オープンソースカンファレンス 2009 Okinawa ( 土 ) ( 独立行政法人情報処理推進機構 (IPA) オープンソフトウェアセンター斉藤浩 ) より引用 Copyright 2009 Japan Users Group

7 pgbouncer : インストール提供サイトのから安定版をダウンロード (pgbouncer ) ビルドは所定の作業ディレクトリにpgbouncerを展開し, configure with-libevent=/prefix; make; make install; を実行 (libevent-1.3b 以降が必要からダウンロードしてインストール libevent stable ) pgbouncer 構成ファイルを編集するバイナリパッケージ RHEL5 用には PGDG yum リポジトリもある Windows 版バイナリはさいとうひろし氏のサイト Copyright 2009 Japan Users Group

8 pgbouncer: プーリング方式 Session Pooling 最も堅実な方法クライアントが接続すると 1 つのサーバ接続が接続の間持続して割り当てられるクライアントの接続が切れたときサーバ接続はプールに戻されるレガシーアプリではこの方式が有用 Transaction pooling サーバ接続が 1 つのトランザクションの間だけ割り当てられる pgbouncer がそのトランザクションが終了したことを認識した時点でサーバ接続はプールに戻されるバックエンド接続したアプリケーションの例外で壊す恐れがあるので要注意アプリケーションと協調をとって使い方を注意しクライアントを壊す恐れのない機能のみを使うべき Statement pooling 最も活性的なプール方法マルチステートメントのトランザクションには使えないすなわち autocommit モードをクライアントに強制し PL/Proxy との連携が主な目的 Copyright 2009 Japan Users Group

9 PL/Proxy の特長のストアドプロシージャ言語 (PL/pgsql) で書かれた拡張モジュールリモートデータベースのプロシージャを呼び出すためのプロキシー言語例えばフィールド値のハッシュをもとにデータベース間にデータを分割 ( 構成関数で定義 ) リモート関数と同じ名前のプロキシー関数を作成し行き先の情報はプロキシー関数の中で指定 Copyright 2009 Japan Users Group

10 plproxy のモジュール構成 P o s t g r e S Q L plproxy 構成 (schema) connect DB p1 plproxy Libpq (client) DB p2 本体の contrib モジュールと同じ build 手順で作成クライアント認証は本体 (libpq) が行います plproxy+pgbouncer を使ってみよう! オープンソースカンファレンス 2009 Okinawa ( 土 ) ( 独立行政法人情報処理推進機構 (IPA) オープンソフトウェアセンター斉藤浩 ) より引用 Copyright 2009 Japan Users Group

11 plproxy: インストール提供サイトのから安定版をダウンロード (plproxy ) ビルドは所定の作業ディレクトリに plproxy を展開して make; make install; を実行 ( 問題が起きる場合は pg_config 等の実行バイナリディレクトリに path が通っているか確認ターゲットのデータベースへ plproxy 機能をインストールするために plproxy.sql ファイルをロードする # psql -f $PGSHARE/contrib/plproxy.sql mydb plproxy の動作確認のためにテスト機能を作成バイナリパッケージ RHEL5 用など PGDG yum リポジトリもある Windows 版バイナリはさいとうひろし氏のサイト Copyright 2009 Japan Users Group

12 plproxy : Language 定義言語は PL/PgSQL と類似ストリングの引用コメント行末のセミコロンステートメントは 4 つだけ CONNECT, CLUSTER, RUN, SELECT 各々の機能はどのデータベースで SQL を実行させるべきかを決定するために CONNECT か CLUSTER ステートメントと RUN ステートメントのペア構成が必要 CONNECT libpq connstr ; クエリを接続し実行するために場所を指定複数機能が同じ connstr を持てば同じ接続を使用 CLUSTER cluster_name ; 実行する cluster name を指定 cluster name は plproxy.get_cluster_* 機能で pass されたもの CLUSTER cluster_func(..); proxy 機能引数と同時にクラスタ名をダイナミックに決定 cluster_func はクラスタ名文字列を返す Copyright 2009 Japan Users Group

13 plproxy : Configuration スキーマ : 以下の 3 つの構成機能は plproxy のために必須 ( これらは PL/pgsql で記述する関数 ) plproxy.get_cluster_partitions(cluster_name text) リモートのデータベースへ接続する際指定されている plproxy の接続文字列で初期化 plproxy.get_cluster_version(cluster_name text) plproxy の構成が変更された場合再読込みが必要全ての機能が plproxy を経由するためできる限り早く呼ばれるべき plproxy.get_cluster_config( in cluster_name text, out key text,out val text) 接続が確立している間 plproxy パラメータを変更することができる Copyright 2009 Japan Users Group

14 plproxy :Language RUN ON... RUN ON ALL; RUN ON ANY; クエリを cluster 内の全パーティションで並列実行ランダムにいづれかのパーティションで実行 RUN ON <NR>; パーティション番号 <NR> の上で実行 RUN ON partition_func(..); 1 つ以上のハッシュ値 (int4) を返す partition_func() に指定した関数を実行 RUN ON argument; 変数 ( 例 $1) でパーティション番号を指定クエリはタグ付けされたパーティションで実行される複数のパーティションにタグ付けされればクエリはそれらのパーティションで並列実行される Copyright 2009 Japan Users Group

plproxy+pgbouncer の実装例 pgbouncer id=0001~1000 DBPart1 plproxy Web Application

16 pgbouncer 構成例 ;; database name = connect string [databases] proxy = host= port=54320 dbname=jpug user=jpug password=pass part1 = host= port=54321 dbname=jpug user=jpug password=pass part2 = host= port=54322 dbname=jpug user=jpug password=pass ;; Configuation section [pgbouncer] admin_users = admin stats_users = stat_collector logfile = /home/jpug/pgsql/log/pgbouncer_test.log pidfile = /home/jpug/pgsql/log/pgbouncer_test.pid listen_addr = listen_port = 6666 port: 6666 port: pgbounce r p r o x y B port: p a r t 1 port: p a r t 2 auth_type = trust ; any, trust, plain, crypt, md5 auth_file = /home/jpug/pgsql/pgbouncer_test_u.txt pool_mode = session ; session - after client disconnects ; transaction - after transaction finishes ; statement - after statement finishes Copyright 2009 Japan Users Group

17 plproxy: 構成例ユーザ名とメールアドレスからなるテーブルに plproxy を使ってデータを格納してみるわずかな設定変更で格納方法を変更できること格納の仕方による振る舞いの違いを確認する RUN ON hashtext( 名前 ) hashtext() 関数の戻り値 (int) によって複数の格納先パーティションへ振り分ける次ページ以降のサンプル参照 RUN ON ALL 値のセットを返す関数が必要となる (RETRUNS SET OF TEXT) すべてのパーティションに格納される Copyright 2009 Japan Users Group

18 サンプル 1: 各バックエンド DB での登録クラスタ化するデータベースのそれぞれにテーブルの実体と関数を作成する関数名はプロキシ上で登録するものと同じ名前型引数型にする CREATE TABLE ユーザ ( ); ユーザ名 text, メール text -- 各リモート側データベースに定義する挿入関数 create language plpgsql; --- 関数定義のため CREATE OR REPLACE FUNCTION ユーザ挿入 ( ユーザ IN text, メール IN text) RETURNS integer AS $$ INSERT INTO ユーザ ( ユーザ名, メール ) VALUES ($1,$2); SELECT 1; $$ LANGUAGE SQL; port: plproxy schema functions FUNCTION ユーザ挿入 texthash: 0 texthash: 型に注意 --- 型に注意 port: port: CLUSTER FUNCTION ユーザ挿入 TABLE ユーザ FUNCTION ユーザ挿入 TABLE ユーザ Copyright 2009 Japan Users Group

19 サンプル 2a: フロントエンド DB に登録する plproxy 構成 (plpgsql 関数 ) (plproxy.get_cluster_partitions) port: CLUSTER クエリをリモートデータベースに送る必要があるとき plproxy は plproxy.get_cluster_partitions(cluster) 関数を呼び出し各パーティションに送るための接続文字列を取得する ( パーティションの数は 2 の階乗でなくてはならない ) port: plproxy schema functions FUNCTION ユーザメール取得 X texthash: 0 texthash: 1 FUNCTION ユーザメール取得 X TABLE ユーザ port: FUNCTION ユーザメール取得 X CREATE LANGUAGE plpgsql; CREATE SCHEMA plproxy; --- plproxy 関数用スキーマ CREATE OR REPLACE FUNCTION plproxy.get_cluster_partitions(cluster_name text) RETURNS SETOF text AS $$ BEGIN IF cluster_name = ' クラスタ ' THEN RETURN NEXT 'port=54321 host= dbname=jpug user=jpug'; RETURN NEXT 'port=54322 host= dbname=jpug user=jpug'; RETURN; END IF; RAISE EXCEPTION ' クラスタ名が見つかりません '; END; $$ LANGUAGE plpgsql; Copyright 2009 Japan Users Group

20 サンプル 2b: フロントエンド DB に登録する plproxy 構成 (plpgsql 関数 ) (plproxy.get_cluster_version) plproxy.get_cluster_version(cluster_name) 関数はリクエスト毎に呼び出され plproxy.get_cluster_partitions() の結果キャッシュを出力として再利用できるかどうか決定する CREATE OR REPLACE FUNCTION plproxy.get_cluster_version(cluster_name text) RETURNS int4 AS $$ BEGIN IF cluster_name = ' クラスタ ' THEN RETURN 1; END IF; RAISE EXCEPTION ' クラスタ名が見つかりません '; END; $$ LANGUAGE plpgsql; Copyright 2009 Japan Users Group

21 サンプル 2c: フロントエンド DB に登録する plproxy 構成 (plpgsql 関数 ) ( plproxy.get_cluster_config ) plproxy.get_cluster_config() 関数はパラメータを調整するここでは接続の持続時間を設定している他のパラメータについては本体付属文書を参照のこと CREATE OR REPLACE FUNCTION plproxy.get_cluster_config( in cluster_name text, out key text, out val text) RETURNS SETOF record AS $$ BEGIN -- lets use same config for all clusters key := 'connection_lifetime'; val := 30*60; -- 30min. RETURN NEXT; RETURN; END; $$ LANGUAGE plpgsql; Copyright 2009 Japan Users Group

22 サンプル 3: フロントエンド DB に登録する (plproxy 関数 ) ここではユーザテーブルはユーザ名のハッシュ値によっていくつかのデータベースに分散されていることを前提としているパーティショニングされるデータベースへの接続文字列は get_cluster_partitions() 関数の中にある次の関数はプロキシーサーバで実行され適切にパーティショニングされたリモートデータベースから指定ユーザのメールアドレスを取得 CREATE LANGUAGE plproxy; -- プロキシ側データベースに定義する挿入関数 CREATE OR REPLACE FUNCTION ユーザ挿入 ( ユーザIN text, メールIN text) CLUSTER RETURNS integer AS $$ --- 型に注意 CLUSTER ' クラスタ '; RUN ON hashtext( ユーザ IN); $$ LANGUAGE plproxy; --- plproxy 言語登録 port: plproxy schema functions FUNCTION ユーザ挿入 texthash: 0 port: FUNCTION ユーザ挿入 port: TABLE ユーザ texthash: 1 FUNCTION ユーザ挿入 TABLE ユーザ Copyright 2009 Japan Users Group

24 謝辞オープンソースに興味を持ち集まってくださった皆様に感謝いたします本セミナーのために資料をご提供くださった独立行政法人情報処理推進機構 (IPA) オープンソフトウェアセンターの斉藤浩様に感謝いたします PL/Proxy, PgBouncer の動作について情報を提供下さった Skype TM 社の Marko Kreen 氏 JPUG のさいとうひろし氏に感謝いたしますならびに PL/Proxy, PgBouncer の開発に貢献くださった人々に感謝いたします Copyright 2009 Japan Users Group

25 おしまいですお疲れさまでしたこんどの JPUG イベントはこれだ! 今のうちにスケジュールを! Conference 2009 Japan JPUG 10th Anniversary Conference 日にち : 2009 年 11 月 20 日 ( 金 )~21 日 ( 土 ) 場所 : AP 浜松町 ( 東京都港区 ) 主催 : 日本ユーザ会運営 : Conference 2009 Japan 実行委員会 Copyright 2009 Japan Users Group

PowerPoint プレゼンテーション

PowerPoint プレゼンテーション PostgreSQL のしくみ勉強会 (2009 年 6 月 20 日 ) PL/Proxy と pgbouncer 講師 : 桑村潤補助 : さいとうひろし PL/Proxy, pgbouncer とは PL/Proxy,pgbouncer は Skype TM 社によって培われたテクノロジで軽量かつ便利に PostgreSQL を活用できるものとして公開された機能 pgbouncer はコネクションプーラー