【入門】GridDB Cloud に VNetを使って触れてみよう!
ビッグデータ・IoT向けデータベース GridDB をDataBase as a Serviceとして提供されるマネージドサービスである GridDB Cloud v1.3がリリースされ、今回GridDB Cloud v1.3のトライアルに触れる機会を得ました。
アプリケーションとGridDBの間をインターネットを介すWeb APIによる接続の方法では、通信の暗号化が必須となり、ネットワークオーバヘッドが大きくなるため、GridDBの特長である高い処理能力を十分に生かすことができません。そこで、下図のようにGridDB Cloudでは、Web APIによる接続方法だけではなく、GridDBとアプリケーションをAzure 仮想プライベートネットワークであるVNet(Azure Virtual Network)ピアリングでも接続することが可能となっています。
VNetピアリングでAzureのバックボーンを用いて直接接続すると。アプリケーションのVNetとGridDBのVNetが直接接続され、セキュリティが確保できるため、通信の暗号化が不要となります。また、HTTPネットワークによる以外のオーバーヘッドが少ないJDBCやODBCなどのプロトコルも利用でき,GridDB本来の処理能力を生かすことができるとのことです。
今回、GridDB Cloud の無料トライアルを入手し、払い出された後に管理コンソール (以下、運用管理GUI) へログインするところから、VNetピアリングを使ってサンプルアプリケーション (Java)とGridDBを接続し、GridDBへのデータ登録・確認をおこなうまでの一連の手順を紹介していきたいと思います。
- 事前準備
- ログイン (運用管理GUIへのログイン)
- 接続設定
- サンプルプログラムの実行と確認
事前準備
無料トライアルの申し込み
GridDB Cloud サイトで、トライアルを申し込むと数日後にGridDB Cloudの トライアルアカウント情報(URL、契約ID、ログインID、パスワード、Web API情報、利用期間情報など)が電子メールで送付されてきます。
例:
GridDB Cloud トライアルへようこそ!
〇〇〇〇〇〇〇
〇〇 〇〇 様
この度は、GridDB Cloudトライアルにお申し込みいただきまして、誠にありがとうございます。
お客様のトライアルアカウント情報をお知らせします。
URL : https://cloud1.griddb.com/portal/
契約ID : trial1301
ログインID : Admin
パスワード : Password
Web API : https://cloud1.griddb.com/trial001/griddb/v2/
利用期間 : YYYY/MM/DD ~ YYYY/MM/DD
GridDB Cloudトライアルのご利用方法はクイックスタートガイドをご確認ください。
また、WebAPIのIPアドレス制限を実施したい場合や
ご質問などがございましたら、[email protected] までご連絡ください。
なお、無料トライアルの利用期間は、原則1回限り1カ月間。また、GridDB Cloud サービスの評価に限り、日本国内に限って無償で使用できるとのことです。詳細は、GridDB Cloud トライアル利用規約をお読みください。
Microsoft Azure環境の用意
クライアントAPI(Java/C API)を用いたアプリケーションを開発することでGridDB CloudのGridDBに接続できます。その場合、アプリケーションをAzureのプライベートネットワークVNetに配置する必要があります。そして、アプリケーションを配置するVNetとGridDBが動作するVNetを、VNetピアリングを使って接続します。
すなわち、ローカルにアプリケーションを配置し、GridDB CloudのGridDB へ接続するのではなく、事前にAzureサブスクリプションで、Azure上にVNet を設定し、アプリケーションを配置する仮想マシン (VM、Virtual Machine) 等のリソースを用意し、VNetピアリングを用いて接続します。VNetピアリング確立後は、プライベートIPアドレスを指定して通信できるようになります。VNetピアリングは従量課金のサービスですので、利用料金など詳細な仕様について知りたい場合は、Microsoftの公式ドキュメントを参照してください。
なお、Azureのアカウントを保持していないなどVNet環境を利用できない場合には、アプリケーションをGridDB Web APIを用いて開発し、そのアプリケーションをローカルなどに配置しGridDBインスタンスとWebAPI経由で接続することもできます。Web APIを利用した接続については「入門】GridDB Cloudにcurlを使ってWeb APIで触れてみよう!」および「【入門】GridDB Cloud にPostmanを使ってWeb APIで触れてみよう!」を参照してください。
ログイン (運用管理GUIへのログイン)
電子メールでが送付されてきたGridDB CloudサービスのURLをブラウザで開きます。今回の例では、https://cloud1.griddb.com/portal/ です。
契約ID、ログインID、パスワード入力し、GridDB Cloudにログインします。
ログインすると、次のような運用管理GUIの画面が表示されます。
この画面では GridDB のクラスタの稼働状況の確認などができるようです。
詳細は、GridDB Cloud 運用管理GUIリファレンス に記述されているみたいなので、ここでは詳細は省略します。
接続設定
次にアプリケーション環境から GridDB Cloud の GridDB に接続するための設定をしてみます。
運用管理GUI でクラウドプロバイダの選択をおこない、VNetの情報を入力し、VNetピアリングを確立するための手順を入手します。そして、Virtual Machine上でその手順を実行し、VNetピアリングを確立し接続します。
クラウドプロバイダの選択
まずは、運用管理GUI の左のナビゲーションメニューより「ネットワークアクセス」のアイコン
をクリックします。
次に、「ピアリング接続を作成」ボタンを選択しクリックします。
そうすると次のようなクラウドプロバイダを選ぶダイアログが表示されます。何も変更せず、「次へ」ボタンをクリックしてください。
VNetの情報入力
VNet Settingsの画面が表示されます。
ここではアプリケーションが配置される VNet の情報を入力します。具体的には次の情報を入力します。
- サブスクリプションID
- テナントID
- リソースグループ名
- VNet名
取得方法がわからない場合は、 をクリックして、取得方法のヒントを表示してください。
なお、ここでは、
- サブスクリプションID: cf0be29e-7532-459b-976e-beb79a6172cb
- テナントID: 1ba2ed3a-1a4b-43a6-bfd1-f6ce9507a6e7
- リソースグループ名: cloud-peering-to-heatrun
- VNet名: cloud-peering-to-heatrun-vnet
としています。
サブスクリプションID、テナントIDリソース、リソースグループ名、VNet名のすべて入力が終わったら、「次へ」ボタンを選択しクリックしてください。
このようなVNetピアリングを確立するための手順のダイアログが表示されます。
VNetピアリングの確立
次に、VNetピアリングを確立するために作成された手順を実行します。
次のいずれかの環境で実行可能です。
- Azureポータルから実行可能なAzure Cloud Shell
ポータル右上にある下記の形をしたアイコンをクリックして開けば、すぐにVNetピアリングを確立するための手順のダイアログのコマンドが実行可能です。
- Azure仮想マシン内で実行可能なAzure CLI
Azure CLIが未インストールの場合はインストールが必要です。VNetピアリングを確立するための手順のダイアログのコマンド実行前に、az loginコマンドなどによるログイン処理が必要です
Azure Cloud ShellやAzure CLIを用いて、表示された1.から4.のコマンドを順に実行します。なお、一部のコマンドにはAzureでの実行権限が必要です。詳しくは、手順の右側のツールチップにマウスカーソルを合わせ、内容を参照してください。
ここでは、Azure CLI を用いて、次のように実行しました。
1.Azure CLIでこのコマンドを実行して、GridDB Cloudのサービスプリンシパルを作成してください
$ az ad sp create --id dceac839-02cf-4361-8fa0-bd8063c4396d
2. このロール定義をpeering-role.jsonとしてカレントディレクトリに保存してください
viコマンドなどで peering-role.json ファイルに書き込みます。
3. このコマンドを実行してpeering-role.jsonを使ってロールを作成してください
手順2で定義したロール
$ az role definition create --role-definition peering-role.json
4. このコマンドを実行して、ステップ 1で作成したサービスプリンシバルにステップ 3のロールを割り当ててください
$ az role assignment create --role "GridDBCloudPeering/cf0be29e-7532-459b-976e-beb79a6172cb/cloud-peering-to-heatrun/cloud-peering-to-heatrun-vnet" --assignee "1a7718df-aaa5-4e8a-892c-ce4db570706f" --scope "/subscriptions/cf0be29e-7532-459b-976e-beb79a6172cb/resourceGroups/cloud-peering-to-heatrun/providers/Microsoft.Network/virtualNetworks/cloud-peering-to-heatrun-vnet"
5. 接続がただしく動作するかどうかを検証してください
コマンドの実行が完了したら、運用管理GUIのダイアログに戻って左下の「検証」ボタンをクリックして接続状態を確認してください。
接続が確認できたら、「ピアリングを作成」ボタンを押して、VNet ピアリングを確立します。
VNetピアリングの状態確認
「ピアリング接続を作成」をクリックし、ピアリング接続リストの一覧に戻り、「ステータス」が接続となっていれば VNet ピアリング確立が成功です。これで GridDB のプライベートIPアドレスを使った通信が可能となりました。
なお、AzureポータルからVNetピアリングを削除した場合などは、「ステータス」が未接続となります。再度接続したい場合は、新たにVNetピアリングを確立してください。
また、GridDBとアプリケーションの配置されるネットワークアドレスが競合する場合は VNetピアリングを確立することができません。その場合は、アプリケーションが配置されるネットワークアドレスを変更してください。
サンプルプログラムの実行と確認
ここでは、アプリケーションプログラムからGridDBにデータを登録する方法について紹介します。
アプリケーション開発 (クライアントAPI) ライブラリ
アプリケーション開発(クライアントAPI) ライブラリの取得
運用管理GUIで、左のナビゲーションメニューより「サポート」を選択しますクリックします。
「GridDB Cloud ライブラリ/プラグインダウンロード」の「ファイルダウンロード」のURLリンクからダウンロードをおこないます。
Azure CLIで、curlコマンドなどを用いて、Virtual Machineにダウンロードします。
$ curl 'https://dbaassharefilest.blob.core.windows.net/file/GridDB_Cloud_doc_lib.zip?sv=2020-02-10&ss=b&srt=o&sp=r&se=2026-04-06T14:59:59Z&st=2021-04-06T02:37:13Z&spr=https&sig=nsp9dFZeR3anSkZ4daqx1IWzx3fHz9iPH9jHvsrScb4%3D' -o GridDB_Cloud_doc_lib.zip
% Total % Received % Xferd Average Speed Time Time Time Current2021-04-06T02:37:13Z&spr=https&sig=nsp9dFZeR3an
Dload Upload Total Spent Left Speed
100 28.8M 100 28.8M 0 0 11.8M 0 0:00:02 0:00:02 --:--:-- 11.8M
$ ls
GridDB_Cloud_doc_lib.zip
$ unzip GridDB_Cloud_doc_lib.zip
Archive: GridDB_Cloud_doc_lib.zip
creating: GridDB_Cloud_doc_lib/
creating: GridDB_Cloud_doc_lib/embulk-output-griddb/
inflating: GridDB_Cloud_doc_lib/embulk-output-griddb/build.gradle
creating: GridDB_Cloud_doc_lib/embulk-output-griddb/config/
inflating: GridDB_Cloud_doc_lib/embulk-output-griddb/config.yml
(省略)
$
なお、GridDB_Cloud_doc_lib.zipを保存しているストレージは、匿名アクセスを無効にしているようです。だから、wgetコマンドを使用した場合、ストレージ上では匿名アクセスとして扱われ、結果として、アクセスを拒否されてしますのでご注意を願います。
GridDB_Cloud_doc_lib.zipを解凍すると次のようになります。
$ cd GridDB_Cloud_doc_lib/
$ ls -l
total 21748
drwxrwxr-x. 6 azgsadm azgsadm 230 Oct 15 10:34 embulk-output-griddb
drwxrwxr-x. 6 azgsadm azgsadm 4096 Mar 7 13:22 fluent-plugin-griddb
-rw-rw-r--. 1 azgsadm azgsadm 10793 Jul 1 2021 gdbConnectSample.zip
drwxrwxr-x. 8 azgsadm azgsadm 4096 Oct 15 10:37 grafana-input-plugin
-rw-rw-r--. 1 azgsadm azgsadm 1200152 Sep 13 2021 griddb-ee-c_lib-4.6.0-linux.x86_64.rpm
-rw-rw-r--. 1 azgsadm azgsadm 1452988 Sep 13 2021 griddb-ee-java_lib-4.6.0-linux.x86_64.rpm
-rw-rw-r--. 1 azgsadm azgsadm 19587096 Sep 14 2021 griddb-ee-webapi-4.6.0-linux.x86_64.rpm
drwxrwxr-x. 2 azgsadm azgsadm 218 Oct 15 11:24 JDBC
drwxrwxr-x. 5 azgsadm azgsadm 202 Mar 7 11:35 logstash-output-plugin
drwxrwxr-x. 4 azgsadm azgsadm 61 Oct 15 11:24 ODBC
drwxrwxr-x. 3 azgsadm azgsadm 88 Mar 7 11:31 telegraf-output-plugin
griddb-ee-java_lib-4.6.0-linux.x86_64.rpm がJava用クライアントAPIライブラリのrpmパッケージです。
アプリケーション開発ライブラリ (クライアントAPI) のインストール
Java用クライアントAPIライブラリのインストール
今回、Java言語でコーディングされたサンプルプログラムを実行させますので、rpmコマンドを用いて Java サンプルプログラムのビルドで利用するJava用クライアントAPIのライブラリをインストールします。
Verifying... ################################# [100%]
Preparing... ################################# [100%]
Updating / installing...
1:griddb-ee-java_lib-4.6.0-linux ################################# [100%]
$
サンプルプログラムの作成
サンプルプログラムの処理概要
サンプルプログラムは、接続情報を引数で受け取り、次のような流れでデータの登録・表示をおこなうものです。
- 接続パラメータの設定
- 接続用インスタンスの作成
- 接続し、コンテナ(コンテナ名:point01)を作成
TIMESTAMP, BOOL, DOUBLEの3カラムで構成 - ロウを登録
(現在時刻, false, 100.0)を登録 - 過去6時間以内に登録されたロウを表示
サンプルプログラムソースコード
サンプルプログラムのソースコードは次の通りです。このソースコードをコピーし、cloud_sample.javaというファイル名で任意のディレクトリに保存してください。
GridDBの接続方式には、マルチキャスト方式、固定リスト方式、プロバイダ方式の3種類がありますが、GridDB Cloudでは、サンプルプログラムで指定したプロバイダ方式 (Notification Provider URLを接続先として指定する方式) のみが有効で、他の方式には対応していません。
import java.util.Date;
import java.util.Properties;
import com.toshiba.mwcloud.gs.GSException;
import com.toshiba.mwcloud.gs.GridStore;
import com.toshiba.mwcloud.gs.GridStoreFactory;
import com.toshiba.mwcloud.gs.RowKey;
import com.toshiba.mwcloud.gs.RowSet;
import com.toshiba.mwcloud.gs.TimeSeries;
import com.toshiba.mwcloud.gs.TimestampUtils;
import com.toshiba.mwcloud.gs.TimeUnit;
// Storage and extraction of a specific range of time-series data
public class cloud_sample {
static class Point {
@RowKey Date timestamp;
boolean active;
double voltage;
}
public static void main(String[] args) throws GSException {
// Acquiring a GridStore instance
Properties props = new Properties();
props.setProperty("notificationProvider", args[0]);
props.setProperty("clusterName", args[1]);
props.setProperty("user", args[2]);
props.setProperty("password", args[3]);
GridStore store = GridStoreFactory.getInstance().getGridStore(props);
// Creating a TimeSeries (Only obtain the specified TimeSeries if it already exists)
TimeSeries<Point> ts = store.putTimeSeries("point01", Point.class);
// Preparing time-series element data
Point point = new Point();
point.active = false;
point.voltage = 100;
// Store the time-series element (GridStore sets its timestamp)
ts.append(point);
// Extract the specified range of time-series elements: last six hours
Date now = TimestampUtils.current();
Date before = TimestampUtils.add(now, -6, TimeUnit.HOUR);
RowSet<Point> rs = ts.query(before, now).fetch();
while (rs.hasNext()) {
point = rs.next();
System.out.println(
"Time=" + TimestampUtils.format(point.timestamp) +
" Active=" + point.active +
" Voltage=" + point.voltage);
}
// Releasing resource
store.close();
}
}
サンプルプログラムのコンパイル
Java用クライアントAPIライブラリは、/usr/share/javaにインストールされているので、そのパスを通し、サンプルプログラムをコンパイルします。
$ export CLASSPATH=${CLASSPATH}:/usr/share/java/gridstore.jar
$ javac cloud_sample.java
$ ls
'cloud_sample$Point.class' cloud_sample.class cloud_sample.java
これで、サンプルプログラムが作成されました。次は、接続情報をメモし引数に入れてプログラムを実行します。
接続情報の確認
作成したプログラムを実行する前に、接続情報の確認と、データベースユーザの作成を行います。
まずは接続情報の確認をします。「クラスタ」画面に遷移し、次の接続情報をメモしてください。
- クラスタ名 (クラスタ詳細の左上)
- アドレスプロバイダのURL(クラスタ詳細の右下)
今回の例では、クラスタ名:「gs_clustertrial1301」、アドレスプロバイダのURL:「http://dbaassharegssta.blob.core.windows.net/dbaas-share-griddb-blob/trial1301.json 」となります。
データベースユーザの作成
データベースサンプルプログラムを実行するにあたり、データベースユーザを作成します。「GridDBユーザ」画面に遷移し、「データベースユーザの作成」ボタンをクリックしてください。
任意のユーザ名とパスワードを設定し、「作成」ボタンをクリックします。
ここでは、:ユーザ名:「test_user1」、パスワード:「test_user1」としました。
「作成」をクリックします。
データベースユーザ名とそのパスワードが設定されました。
サンプルプログラムの実行
$ java cloud_sample <Notification Provider URL> <クラスタ名> <データベースユーザ名> <データベースユーザパスワード>
実際に、サンプルプログラムを実行してみます。
$ java cloud_sample http://dbaassharegssta.blob.core.windows.net/dbaas-share-griddb-blob/trial1301.json gs_clustertrial1301 test_user1 test_user1
Time=2022-03-23T09:25:03.933Z Active=false Voltage=100.0
$
このような実行結果が表示されれば成功です。
サンプルプログラムによる登録データの確認
運用管理GUIで、サンプルプログラムによる登録データを確認してみましょう。
「クエリ」画面を開きます。右側にサンプルプログラムで作成したコンテナ point01があることを確認します。
SQL実行
次に、point01のデータをすべて取得するSQL文 SELECT * FROM point01
を入力し、実行ボタン
を押します。
実行結果が次のように表示されていれば成功です。
TQL実行
GridDB Cloud v1.1より、「クエリ」画面で、TQLが実行できるようになりました。
「クエリ」画面 の画面右側のSQL/TQLスイッチボタンでTQLを選択します。
「コンテナを選択」で、コンテナ名としてpoint01を選択します。
データをすべて取得するSQL文 SELECT *
が入力されているので、実行ボタン
を押します。
SQL実行結果の上に同じ結果が上書きされます。
さいごに
今回、ビッグデータ・IoT向けデータベース GridDB をDB as a Serviceとして提供されるマネージドサービスである GridDB Cloud の無料トライアルを入手し、払い出された後に運用管理GUIへログインするところから、GridDBの特長である高い処理能力を十分に生かすために、Web APIによる接続方法だけではなく、GridDBとアプリケーションをVNet(Azure Virtual Network)ピアリングを使ってサンプルアプリケーション (Java)とGridDBを接続し、GridDBへのデータ登録・確認をおこなうまでの一連の手順を紹介しました。
ローカル環境などからのWeb APIを利用した接続については「入門】GridDB Cloudにcurlを使ってWeb APIで触れてみよう!」および「【入門】GridDB Cloud にPostmanを使ってWeb APIで触れてみよう!」を参照していただければと思います。
なお、記述について誤りがあったり、気になることがあれば、編集リクエストやコメントでフィードバックしていただけると助かります。
Author And Source
この問題について(【入門】GridDB Cloud に VNetを使って触れてみよう!), 我々は、より多くの情報をここで見つけました https://zenn.dev/gahoh/articles/4208d33aa0abac著者帰属:元の著者の情報は、元のURLに含まれています。著作権は原作者に属する。
Collection and Share based on the CC protocol