SQL Server テーブルから読み取る

このページでは、Microsoft SQL Server テーブルからデータを読み取るようにデータ パイプラインを設定する方法について説明します。

始める前に

  1. Google Cloud アカウントにログインします。 Google Cloudを初めて使用する場合は、 アカウントを作成して、実際のシナリオでの Google プロダクトのパフォーマンスを評価してください。新規のお客様には、ワークロードの実行、テスト、デプロイができる無料クレジット $300 分を差し上げます。

  2. In the Google Cloud console, on the project selector page, select or create a Google Cloud project.

    Roles required to select or create a project

    • Select a project: Selecting a project doesn't require a specific IAM role—you can select any project that you've been granted a role on.
    • Create a project: To create a project, you need the Project Creator role (roles/resourcemanager.projectCreator), which contains the resourcemanager.projects.create permission. Learn how to grant roles.

    Go to project selector

  3. Verify that billing is enabled for your Google Cloud project.

  4. In the Google Cloud console, on the project selector page, select or create a Google Cloud project.

    Roles required to select or create a project

    • Select a project: Selecting a project doesn't require a specific IAM role—you can select any project that you've been granted a role on.
    • Create a project: To create a project, you need the Project Creator role (roles/resourcemanager.projectCreator), which contains the resourcemanager.projects.create permission. Learn how to grant roles.

    Go to project selector

  5. Verify that billing is enabled for your Google Cloud project.

  6. Cloud Data Fusion API、BigQuery API、Cloud Storage API、Dataproc API を有効にします。

    API を有効にするために必要なロール

    API を有効にするには、serviceusage.services.enable 権限を含む Service Usage 管理者 IAM ロール（roles/serviceusage.serviceUsageAdmin）が必要です。詳しくは、ロールを付与する方法をご覧ください。

    API を有効にする

  7. Cloud Data Fusion インスタンスを作成します。
  8. SQL Server データベースが Cloud Data Fusion からの接続を受け入れる必要があります。セキュリティ上の理由から、プライベート Cloud Data Fusion インスタンスを使用してください。

Cloud Data Fusion インスタンスを開く

  1. Google Cloud コンソールで、Cloud Data Fusion の [インスタンス] ページに移動します。

    [インスタンス] に移動

  2. インスタンスの [操作] 列で、[インスタンスを表示] をクリックして、Cloud Data Fusion でインスタンスを開きます。

SQL Server のパスワードをセキュリティ キーとして保存する

Cloud Data Fusion インスタンスに、SQL Server のパスワードを安全な鍵として追加します。

  1. Cloud Data Fusion で、[システム管理] をクリックします。

  2. [構成] タブをクリックします。

  3. [Make HTTP Calls] をクリックします。

    [Configuration] タブ。

  4. [PUT] を選択します。

  5. [Path] フィールドに「namespaces/NAMESPACE_ID/securekeys/password 」と入力します。

  6. [Body] フィールドに「{"data":"password"}」と入力します。 password は SQL Server のパスワードに置き換えます。

  7. [送信] をクリックします。

    パスワード。

続行するには、[レスポンス] にステータス コード 200 が表示されている必要があります。

SQL Server の JDBC ドライバを取得する

ドライバは、ハブまたは Cloud Data Fusion の Pipeline Studio から入手できます。

ハブ

  1. Cloud Data Fusion UI で、[Hub] をクリックします。

  2. 検索バーに「SQL Server JDBC Driver」と入力して、ドライバを選択します。

  3. [ダウンロード] をクリックします。表示されたダウンロード手順に沿って操作します。

  4. [Deploy] をクリックします。前の手順で作成した Jar ファイルをアップロードします。

  5. [完了] をクリックします。

Pipeline Studio

  1. Microsoft.com にアクセスします。

  2. ダウンロードするファイルを選択して、[ダウンロード] をクリックします。

  3. Cloud Data Fusion で、 メニューをクリックし、[Pipeline Studio] ページに移動します。

  4. [追加] をクリックします。

  5. ドライバの場合は、[アップロード] をクリックします。

  6. jre7 フォルダにある JAR ファイルを選択します。

  7. [Next] をクリックします。

  8. ドライバを構成するには、[名前] と [クラス名] に入力します。

  9. [完了] をクリックします。

SQL Server プラグインをデプロイする

  1. Cloud Data Fusion で [Hub] をクリックします。

  2. 検索バーに「SQL Server Plugins」と入力します。

  3. [SQL Server プラグイン] をクリックします。

  4. [デプロイ] をクリックします。

  5. [完了] をクリックします。

  6. [Create a pipeline] をクリックします。

SQL Server に接続する

Wrangler または Pipeline Studio の Cloud Data Fusion から SQL Server に接続できます。

Wrangler

  1. Cloud Data Fusion で、 メニューをクリックし、[Wrangler] ページに移動します。

  2. [Add connection] をクリックします。

    [接続を追加] ウィンドウが開きます。

  3. [SQL Server] をクリックして、ドライバがインストールされていることを確認します。

    アップロードされた JAR。

  4. 必要な接続フィールドに詳細情報を入力します。[Password] フィールドで、前に保存したセキュリティ キーを選択します。これにより、Cloud KMS を使用してパスワードが取得されるようになります。

    パスワードを設定。

  5. データベースとの接続を確立できることを確認するには、[テスト接続] をクリックします。

  6. [Add connection] をクリックします。

SQL Server データベースが接続され、SQL Server テーブルから読み取るパイプラインを作成したら、変換を適用して出力をシンクに書き込むことができます。

Pipeline Studio

  1. Cloud Data Fusion インスタンスを開き、[Pipeline Studio] ページに移動します。

  2. [ソース] メニューを展開し、[SQL Server] をクリックします。

    SQL Server

  3. [SQL Server] ノードで、[プロパティ] をクリックします。

    プロパティ

  4. [参照名] フィールドに、SQL Server ソースを識別する名前を入力します。

  5. [データベース] フィールドに、接続先のデータベースの名前を入力します。

  6. [インポート クエリ] フィールドに、実行するクエリを入力します。例: SELECT * FROM table WHERE $CONDITIONS。

  7. [検証] をクリックします。

  8. [閉じる] をクリックします。

SQL Server データベースが接続され、SQL Server テーブルから読み取るパイプラインを作成したら、必要な変換を追加して、出力をシンクに書き込みます。

次のステップ