チュートリアル:SQL Server データベースから Azure Blob Storage にデータをコピーする

[アーティクル]
10/03/2024

適用対象: Azure Data Factory Azure Synapse Analytics

ヒント

企業向けのオールインワン分析ソリューション、Microsoft Fabric の Data Factory をお試しください。 Microsoft Fabric は、データ移動からデータサイエンス、リアルタイム分析、ビジネスインテリジェンス、レポートまで、あらゆるものをカバーしています。無料で新しい試用版を開始する方法について説明します。

このチュートリアルでは、SQL Server データベースから Azure Blob Storage にデータをコピーするデータファクトリパイプラインを Azure PowerShell を使って作成します。セルフホステッド統合ランタイムを作成して使用すると、オンプレミスデータストアとクラウドデータストア間でデータを移動できます。

Note

この記事では、Data Factory サービスの概要については詳しく取り上げません。詳細については、Azure Data Factory の概要に関するページをご覧ください。

このチュートリアルでは、以下の手順を実行します。

データファクトリを作成します。
セルフホステッド統合ランタイムを作成します。
SQL Server と Azure Storage のリンクされたサービスを作成します。
SQL Server と Azure BLOB のデータセットを作成します。
コピーアクティビティでデータを移動するパイプラインを作成します。
パイプラインの実行を開始します。
パイプラインの実行を監視します。

前提条件

Azure サブスクリプション

Azure サブスクリプションをお持ちでない場合は、開始する前に無料アカウントを作成してください。

Azure ロール

Data Factory インスタンスを作成するには、Azure へのサインインに使用するユーザーアカウントが、"共同作成者" または "所有者" ロールに属しているか、Azure サブスクリプションの "管理者" である必要があります。

サブスクリプションで自分が持っているアクセス許可を表示するには、Azure Portal で右上隅にあるユーザー名をクリックし、 [アクセス許可] を選択します。複数のサブスクリプションにアクセスできる場合は、適切なサブスクリプションを選択します。ロールにユーザーを追加する手順の例については、「Azure portal を使用して Azure ロールを割り当てる」を参照してください。

SQL Server 2014、2016、2017

このチュートリアルでは、SQL Server データベースを "ソース" データストアとして使用します。このチュートリアルで作成するデータファクトリ内のパイプラインは、この SQL Server データベース (ソース) から Azure Blob Storage (シンク) にデータをコピーします。 SQL Server データベース内に emp という名前のテーブルを作成し、このテーブルにサンプルエントリをいくつか挿入します。

SQL Server Management Studio を起動します。ご使用のマシンにまだインストールされていない場合は、「SQL Server Management Studio のダウンロード」にアクセスしてください。
自分の資格情報で SQL Server インスタンスに接続します。
サンプルデータベースを作成します。ツリービューで [データベース] を右クリックし、 [新しいデータベース] を選択します。
[新しいデータベース] ウィンドウで、データベースの名前を入力し、 [OK] を選択します。
emp テーブルを作成していくつかのサンプルデータを挿入するために、次のクエリスクリプトをデータベースに対して実行します。ツリービューで、作成したデータベースを右クリックし、 [新しいクエリ] をクリックします。
```
CREATE TABLE dbo.emp
(
    ID int IDENTITY(1,1) NOT NULL,
    FirstName varchar(50),
    LastName varchar(50)
)
GO

INSERT INTO emp (FirstName, LastName) VALUES ('John', 'Doe')
INSERT INTO emp (FirstName, LastName) VALUES ('Jane', 'Doe')
GO
```

Azure ストレージアカウント

このチュートリアルでは、コピー先/シンクデータストアに汎用の Azure Storage アカウント (具体的には Azure Blob Storage) を使用します。汎用の Azure Storage アカウントがない場合は、「ストレージアカウントの作成」をご覧ください。このチュートリアルで作成するデータファクトリ内のパイプラインは、SQL Server データベース (ソース) からこの Azure Blob Storage (シンク) にデータをコピーします。

ストレージアカウント名とアカウントキーの取得

このチュートリアルでは、Azure ストレージアカウントの名前とキーを使用します。以下の手順に従って、ご利用のストレージアカウントの名前とキーを取得してください。

Azure のユーザー名とパスワードを使用して、Azure Portal にサインインします。
左側のウィンドウの [その他のサービス] を選択し、「ストレージ」というキーワードでフィルタリングして、 [ストレージアカウント] を選択します。
ストレージアカウントの一覧で、ご利用のストレージアカウントを (必要に応じて) フィルターで抽出し、該当するストレージアカウントを選択します。
[ストレージアカウント] ウィンドウで [アクセスキー] を選択します。
[ストレージアカウント名] ボックスと [key1] ボックスの値をコピーし、メモ帳などのエディターに貼り付けます。これらの値は、後でこのチュートリアルの中で使用します。

adftutorial コンテナーの作成

このセクションでは、adftutorial という名前の BLOB コンテナーを Azure Blob Storage に作成します。

[ストレージアカウント] ウィンドウで [概要] に切り替え、 [BLOB] を選択します。
[Blob service] ウィンドウで [コンテナー] を選択します。
[新しいコンテナー] ウィンドウの [名前] ボックスに「adftutorial」と入力し、 [OK] を選択します。
コンテナーの一覧で、 [adftutorial] を選択します。
adftutorial の [コンテナー] ウィンドウを開いたままにしておきます。チュートリアルの最後で、このページを使用して出力を確認します。このコンテナーには output フォルダーが Data Factory によって自動的に作成されます。手動で作成する必要はありません。

Windows PowerShell

Azure PowerShell をインストールする

注意

Azure を操作するには、Azure Az PowerShell モジュールを使用することをお勧めします。作業を始めるには、「Azure PowerShell をインストールする」を参照してください。 Az PowerShell モジュールに移行する方法については、「AzureRM から Az への Azure PowerShell の移行」を参照してください。

ご利用のマシンに最新バージョンの Azure PowerShell がまだインストールされていない場合はインストールします。詳しい手順については、「 Azure PowerShell のインストールおよび構成方法」をご覧ください。

PowerShell にログインする

ご利用のマシンで PowerShell を起動します。このクイックスタートチュートリアルが終わるまで開いたままにしてください。 Azure PowerShell を閉じて再度開いた場合は、これらのコマンドをもう一度実行する必要があります。
次のコマンドを実行して、Azure Portal へのサインインに使用する Azure ユーザー名とパスワードを入力します。
```
Connect-AzAccount
```
複数の Azure サブスクリプションがある場合は、次のコマンドを実行して、使用するサブスクリプションを選択します。 SubscriptionId は、実際の Azure サブスクリプションの ID に置き換えてください。
```
Select-AzSubscription -SubscriptionId "<SubscriptionId>"   	
```

Data Factory の作成

後で PowerShell コマンドで使用できるように、リソースグループ名の変数を定義します。次のコマンドを PowerShell にコピーし、Azure リソースグループの名前を二重引用符で囲んで ("adfrg" のように) 指定し、コマンドを実行します。
```
$resourceGroupName = "ADFTutorialResourceGroup"
```
Azure リソースグループを作成するには、次のコマンドを実行します。
```
New-AzResourceGroup $resourceGroupName -location 'East US'
```
リソースグループが既に存在する場合、上書きしないようお勧めします。 $resourceGroupName 変数に別の値を割り当てて、コマンドをもう一度実行します。
後で PowerShell コマンドで使用できるように、データファクトリ名の変数を定義します。名前は文字または数字で始まり、英文字、数字、ダッシュ (-) 文字のみを含めることができます。

重要

データファクトリ名は、グローバルに一意となるように更新してください。たとえば、ADFTutorialFactorySP1127 とします。
```
$dataFactoryName = "ADFTutorialFactory"
```
データファクトリの場所の変数を定義します。
```
$location = "East US"
```
データファクトリを作成するために、次の Set-AzDataFactoryV2 コマンドレットを実行します。
```
Set-AzDataFactoryV2 -ResourceGroupName $resourceGroupName -Location $location -Name $dataFactoryName
```

Note

データファクトリの名前はグローバルに一意にする必要があります。次のエラーが発生した場合は、名前を変更してからもう一度実行してください。
```
The specified data factory name 'ADFv2TutorialDataFactory' is already in use. Data factory names must be globally unique.
```
Data Factory インスタンスを作成するには、Azure へのサインインに使用するユーザーアカウントが、"共同作成者" または "所有者" ロールに属しているか、Azure サブスクリプションの "管理者" である必要があります。
現在 Data Factory が利用できる Azure リージョンの一覧については、次のページで目的のリージョンを選択し、 [分析] を展開して [Data Factory] を探してください。リージョン別の利用可能な製品データファクトリで使用するデータストア (Azure Storage、Azure SQL Database など) やコンピューティング (Azure HDInsight など) は他のリージョンに配置できます。

自己ホスト型統合ランタイムを作成する

このセクションでは、セルフホステッド統合ランタイムを作成し、SQL Server データベースがあるオンプレミスのマシンに関連付けます。セルフホステッド統合ランタイムは、マシンの SQL Server データベースから Azure Blob Storage にデータをコピーするコンポーネントです。

統合ランタイムの名前に使用する変数を作成します。一意の名前を使用し、その名前を書き留めます。このチュートリアルの後の方で、それを使用します。
```
$integrationRuntimeName = "ADFTutorialIR"
```

セルフホステッド統合ランタイムを作成します。

Set-AzDataFactoryV2IntegrationRuntime -ResourceGroupName $resourceGroupName -DataFactoryName $dataFactoryName -Name $integrationRuntimeName -Type SelfHosted -Description "selfhosted IR description"

出力例を次に示します。

Name              : ADFTutorialIR
Type              : SelfHosted
ResourceGroupName : <resourceGroupName>
DataFactoryName   : <dataFactoryName>
Description       : selfhosted IR description
Id                : /subscriptions/<subscription ID>/resourceGroups/<resourceGroupName>/providers/Microsoft.DataFactory/factories/<dataFactoryName>/integrationruntimes/<integrationRuntimeName>

作成された統合ランタイムの状態を取得するために、次のコマンドを実行します。

Get-AzDataFactoryV2IntegrationRuntime -name $integrationRuntimeName -ResourceGroupName $resourceGroupName -DataFactoryName $dataFactoryName -Status

出力例を次に示します。

State                     : NeedRegistration
Version                   :
CreateTime                : 9/10/2019 3:24:09 AM
AutoUpdate                : On
ScheduledUpdateDate       :
UpdateDelayOffset         :
LocalTimeZoneOffset       :
InternalChannelEncryption :
Capabilities              : {}
ServiceUrls               : {eu.frontend.clouddatahub.net}
Nodes                     : {}
Links                     : {}
Name                      : <Integration Runtime name>
Type                      : SelfHosted
ResourceGroupName         : <resourceGroup name>
DataFactoryName           : <dataFactory name>
Description               : selfhosted IR description
Id                        : /subscriptions/<subscription ID>/resourceGroups/<resourceGroupName>/providers/Microsoft.DataFactory/factories/<dataFactoryName>/integrationruntimes/<integrationRuntimeName>

次のコマンドを実行して、クラウドの Data Factory サービスにセルフホステッド統合ランタイムを登録するための "認証キー" を取得します。次の手順でマシンにインストールするセルフホステッド統合ランタイムを登録するために、いずれかのキーをコピーします (二重引用符は除外)。
```
Get-AzDataFactoryV2IntegrationRuntimeKey -Name $integrationRuntimeName -DataFactoryName $dataFactoryName -ResourceGroupName $resourceGroupName | ConvertTo-Json
```
出力例を次に示します。
```
{
    "AuthKey1":  "IR@0000000000-0000-0000-0000-000000000000@xy0@xy@xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx=",
    "AuthKey2":  "IR@0000000000-0000-0000-0000-000000000000@xy0@xy@yyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyyy="
}
```

統合ランタイムのインストール

Azure Data Factory Integration Runtime をローカルの Windows マシンにダウンロードし、インストールを実行します。
[Welcome to Microsoft Integration Runtime Setup](Microsoft Integration Runtime セットアップへようこそ) ウィザードで [次へ] を選択します。
[使用許諾契約書] ウィンドウで使用条件とライセンス契約に同意し、 [次へ] を選択します。
[インストール先フォルダー] ウィンドウで [次へ] を選択します。
[Ready to install Microsoft Integration Runtime](Microsoft Integration Runtime のインストール準備完了) ウィンドウで [インストール] を選択します。
[Completed the Microsoft Integration Runtime Setup](Microsoft Integration Runtime セットアップの完了) ウィザードで [完了] を選択します。
[Integration Runtime (セルフホステッド) の登録] ウィンドウで、前のセクションで保存したキーを貼り付け、 [登録] を選択します。
[新しい Integration Runtime (セルフホステッド) ノード] ウィンドウで [完了] を選択します。
セルフホステッド統合ランタイムが正常に登録されると、次のメッセージが表示されます。
[Integration Runtime (セルフホステッド) の登録] ウィンドウで [構成マネージャーの起動] を選択します。
ノードがクラウドサービスに接続されると、次のメッセージが表示されます。
次の手順に従って SQL Server データベースとの接続をテストします。

a. [構成マネージャー] ウィンドウで、 [診断] タブに切り替えます。

b. [データソースの種類] ボックスで [SqlServer] を選択します。

c. サーバー名を入力します。

d. データベース名を入力します。

e. 認証モードを選択します。

f. ユーザー名を入力します。

g. ユーザー名に関連付けられているパスワードを入力します。

h. 統合ランタイムから SQL Server に接続できることを確認するために、 [テスト] を選択します。

接続に成功すると、緑色のチェックマークアイコンが表示されます。それ以外の場合は、失敗を表すエラーメッセージが表示されます。問題を修正し、統合ランタイムから SQL Server インスタンスに接続できるようにします。

前述の値はすべてメモしておいてください。後でこのチュートリアルの中で使用します。

リンクされたサービスを作成します

データストアおよびコンピューティングサービスをデータファクトリにリンクするには、リンクされたサービスをデータファクトリに作成します。このチュートリアルでは、Azure Storage アカウントと SQL Server インスタンスをデータストアにリンクします。リンクされたサービスは、Data Factory サービスが実行時に接続するために使用する接続情報を持っています。

Azure Storage のリンクされたサービスを作成する (コピー先/シンク)

この手順では、Azure Storage アカウントをデータファクトリにリンクします。

次のコードを記述した AzureStorageLinkedService.json という名前の JSON ファイルを C:\ADFv2Tutorial フォルダーに作成します。 ADFv2Tutorial フォルダーがまだ存在しない場合は作成してください。

重要

ファイルを保存する前に、<accountName> と <accountKey> を実際の Azure Storage アカウントの名前とキーに置き換えます。「前提条件」セクションでメモしたものです。
```
{
    "name": "AzureStorageLinkedService",
    "properties": {
        "annotations": [],
        "type": "AzureBlobStorage",
        "typeProperties": {
            "connectionString": "DefaultEndpointsProtocol=https;AccountName=<accountName>;AccountKey=<accountKey>;EndpointSuffix=core.windows.net"
        }
    }
}
```
PowerShell で C:\ADFv2Tutorial フォルダーに切り替えます。
```
Set-Location 'C:\ADFv2Tutorial'
```
リンクされたサービス AzureStorageLinkedService を作成するために、次の Set-AzDataFactoryV2LinkedService コマンドレットを実行します。
```
Set-AzDataFactoryV2LinkedService -DataFactoryName $dataFactoryName -ResourceGroupName $ResourceGroupName -Name "AzureStorageLinkedService" -File ".\AzureStorageLinkedService.json"
```
出力例を次に示します。
```
LinkedServiceName : AzureStorageLinkedService
ResourceGroupName : <resourceGroup name>
DataFactoryName   : <dataFactory name>
Properties        : Microsoft.Azure.Management.DataFactory.Models.AzureBlobStorageLinkedService
```
"ファイルが見つかりません" エラーが表示された場合は、dir コマンドを実行してファイルが存在することを確認します。ファイル名の拡張子が .txt となっている場合 (例: AzureStorageLinkedService.json.txt) は、その拡張子を削除してからもう一度 PowerShell コマンドを実行してください。

SQL Server のリンクされたサービスを作成して暗号化する (ソース)

この手順では、SQL Server インスタンスをデータファクトリにリンクします。

次のコードを使用して、SqlServerLinkedService.json という名前の JSON ファイルを C:\ADFv2Tutorial フォルダーに作成します。

重要

SQL Server への接続に使用する認証に該当するセクションを選んでください。

SQL 認証を使用する場合 (sa):

{  
    "name":"SqlServerLinkedService",
    "type":"Microsoft.DataFactory/factories/linkedservices",
    "properties":{  
        "annotations":[  

        ],
        "type":"SqlServer",
        "typeProperties":{  
            "connectionString":"integrated security=False;data source=<serverName>;initial catalog=<databaseName>;user id=<userName>;password=<password>"
        },
        "connectVia":{  
            "referenceName":"<integration runtime name> ",
            "type":"IntegrationRuntimeReference"
        }
    }
}

Windows 認証を使用する:

{  
    "name":"SqlServerLinkedService",
    "type":"Microsoft.DataFactory/factories/linkedservices",
    "properties":{  
        "annotations":[  

        ],
        "type":"SqlServer",
        "typeProperties":{  
            "connectionString":"integrated security=True;data source=<serverName>;initial catalog=<databaseName>",
            "userName":"<username> or <domain>\\<username>",
            "password":{  
                "type":"SecureString",
                "value":"<password>"
            }
        },
        "connectVia":{  
            "referenceName":"<integration runtime name>",
            "type":"IntegrationRuntimeReference"
        }
    }
}

重要

SQL Server インスタンスへの接続に使用する認証に該当するセクションを選んでください。
<integration runtime name> は、実際の統合ランタイムの名前に置き換えます。
ファイルを保存する前に、<servername>、<databasename>、<username>、<password> を実際の SQL Server インスタンスの値に置き換えます。
ユーザーアカウントまたはサーバー名にバックスラッシュ (\) を使う必要がある場合は、エスケープ文字 (\) に続けて入力してください。たとえば、「mydomain\\myuser」のように入力します。

機密データ (ユーザー名、パスワードなど) を暗号化するには、New-AzDataFactoryV2LinkedServiceEncryptedCredential コマンドレットを実行します。
この暗号化によって、資格情報が Data Protection Application Programming Interface (DPAPI) を使って暗号化されます。暗号化された資格情報は、セルフホステッド統合ランタイムノード (ローカルマシン) のローカルに格納されます。暗号化された資格情報が含まれる出力ペイロードは別の JSON ファイル (この場合は "encryptedLinkedService.json") にリダイレクトできます。
```
New-AzDataFactoryV2LinkedServiceEncryptedCredential -DataFactoryName $dataFactoryName -ResourceGroupName $ResourceGroupName -IntegrationRuntimeName $integrationRuntimeName -File ".\SQLServerLinkedService.json" > encryptedSQLServerLinkedService.json
```

次のコマンドを実行します。これによって、EncryptedSqlServerLinkedService が作成されます。

Set-AzDataFactoryV2LinkedService -DataFactoryName $dataFactoryName -ResourceGroupName $ResourceGroupName -Name "EncryptedSqlServerLinkedService" -File ".\encryptedSqlServerLinkedService.json"

データセットを作成する

この手順では、入力データセットと出力データセットを作成します。これらは、SQL Server Database から Azure Blob Storage にデータをコピーする操作の入出力データを表します。

ソース SQL Server データベースのデータセットを作成する

この手順では、SQL Server データベースインスタンス内のデータを表すデータセットを定義します。データセットの型は、SqlServerTable です。前の手順で作成した SQL Server のリンクされたサービスを参照します。リンクされたサービスは、Data Factory サービスが実行時に SQL Server インスタンスに接続するために使用する接続情報を持っています。このデータセットは、データが含まれる、データベース内の SQL テーブルを指定します。このチュートリアルでは、ソースデータが含まれている emp テーブルです。

以下のコードを記述した SqlServerDataset.json という名前の JSON ファイルを C:\ADFv2Tutorial フォルダー内に作成します。

{  
    "name":"SqlServerDataset",
    "properties":{  
        "linkedServiceName":{  
            "referenceName":"EncryptedSqlServerLinkedService",
            "type":"LinkedServiceReference"
        },
        "annotations":[  

        ],
        "type":"SqlServerTable",
        "schema":[  

        ],
        "typeProperties":{  
            "schema":"dbo",
            "table":"emp"
        }
    }
}

データセット SqlServerDataset を作成するには、Set-AzDataFactoryV2Dataset コマンドレットを実行します。

Set-AzDataFactoryV2Dataset -DataFactoryName $dataFactoryName -ResourceGroupName $resourceGroupName -Name "SqlServerDataset" -File ".\SqlServerDataset.json"

出力例を次に示します。

DatasetName       : SqlServerDataset
ResourceGroupName : <resourceGroupName>
DataFactoryName   : <dataFactoryName>
Structure         :
Properties        : Microsoft.Azure.Management.DataFactory.Models.SqlServerTableDataset

Azure Blob Storage (シンク) のデータセットを作成する

この手順では、Azure Blob Storage にコピーされるデータを表すデータセットを定義します。データセットの型は、AzureBlob です。このチュートリアルの前の方で作成した Azure Storage のリンクされたサービスを参照します。

リンクされたサービスは、データファクトリが実行時に Azure Storage アカウントに接続するために使用する接続情報を持っています。このデータセットは、SQL Server データベースのデータのコピー先となる、Azure Storage 内のフォルダーを指定します。このチュートリアルでは、このフォルダーは adftutorial/fromonprem です。ここで、adftutorial は BLOB コンテナーであり、fromonprem はフォルダーです。

以下のコードを記述した AzureBlobDataset.json という名前の JSON ファイルを C:\ADFv2Tutorial フォルダー内に作成します。

{  
    "name":"AzureBlobDataset",
    "properties":{  
        "linkedServiceName":{  
            "referenceName":"AzureStorageLinkedService",
            "type":"LinkedServiceReference"
        },
        "annotations":[  

        ],
        "type":"DelimitedText",
        "typeProperties":{  
            "location":{  
                "type":"AzureBlobStorageLocation",
                "folderPath":"fromonprem",
                "container":"adftutorial"
            },
            "columnDelimiter":",",
            "escapeChar":"\\",
            "quoteChar":"\""
        },
        "schema":[  

        ]
    },
    "type":"Microsoft.DataFactory/factories/datasets"
}

データセット AzureBlobDataset を作成するには、Set-AzDataFactoryV2Dataset コマンドレットを実行します。

Set-AzDataFactoryV2Dataset -DataFactoryName $dataFactoryName -ResourceGroupName $resourceGroupName -Name "AzureBlobDataset" -File ".\AzureBlobDataset.json"

出力例を次に示します。

DatasetName       : AzureBlobDataset
ResourceGroupName : <resourceGroupName>
DataFactoryName   : <dataFactoryName>
Structure         :
Properties        : Microsoft.Azure.Management.DataFactory.Models.DelimitedTextDataset

パイプラインを作成する

このチュートリアルでは、コピーアクティビティのあるパイプラインを作成します。コピーアクティビティは、入力データセットとして SqlServerDataset を使用し、出力データセットとして AzureBlobDataset を使用します。ソースの種類が SqlSource に設定され、シンクの種類が BlobSink に設定されています。

以下のコードを記述した SqlServerToBlobPipeline.json という名前の JSON ファイルを C:\ADFv2Tutorial フォルダー内に作成します。

{  
    "name":"SqlServerToBlobPipeline",
    "properties":{  
        "activities":[  
            {  
                "name":"CopySqlServerToAzureBlobActivity",
                "type":"Copy",
                "dependsOn":[  

                ],
                "policy":{  
                    "timeout":"7.00:00:00",
                    "retry":0,
                    "retryIntervalInSeconds":30,
                    "secureOutput":false,
                    "secureInput":false
                },
                "userProperties":[  

                ],
                "typeProperties":{  
                    "source":{  
                        "type":"SqlServerSource"
                    },
                    "sink":{  
                        "type":"DelimitedTextSink",
                        "storeSettings":{  
                            "type":"AzureBlobStorageWriteSettings"
                        },
                        "formatSettings":{  
                            "type":"DelimitedTextWriteSettings",
                            "quoteAllText":true,
                            "fileExtension":".txt"
                        }
                    },
                    "enableStaging":false
                },
                "inputs":[  
                    {  
                        "referenceName":"SqlServerDataset",
                        "type":"DatasetReference"
                    }
                ],
                "outputs":[  
                    {  
                        "referenceName":"AzureBlobDataset",
                        "type":"DatasetReference"
                    }
                ]
            }
        ],
        "annotations":[  

        ]
    }
}

パイプライン SQLServerToBlobPipeline を作成するには、Set-AzDataFactoryV2Pipeline コマンドレットを実行します。

Set-AzDataFactoryV2Pipeline -DataFactoryName $dataFactoryName -ResourceGroupName $resourceGroupName -Name "SQLServerToBlobPipeline" -File ".\SQLServerToBlobPipeline.json"

出力例を次に示します。

PipelineName      : SQLServerToBlobPipeline
ResourceGroupName : <resourceGroupName>
DataFactoryName   : <dataFactoryName>
Activities        : {CopySqlServerToAzureBlobActivity}
Parameters        :

パイプラインの実行を作成する

SQLServerToBlobPipeline パイプラインの実行を開始し、後で監視できるようパイプライン実行 ID をキャプチャします。

$runId = Invoke-AzDataFactoryV2Pipeline -DataFactoryName $dataFactoryName -ResourceGroupName $resourceGroupName -PipelineName 'SQLServerToBlobPipeline'

パイプラインの実行を監視します

パイプライン SQLServerToBlobPipeline の実行状態を継続的にチェックするには、PowerShell で次のスクリプトを実行し、最終的な結果を出力します。

while ($True) {
    $result = Get-AzDataFactoryV2ActivityRun -DataFactoryName $dataFactoryName -ResourceGroupName $resourceGroupName -PipelineRunId $runId -RunStartedAfter (Get-Date).AddMinutes(-30) -RunStartedBefore (Get-Date).AddMinutes(30)

    if (($result | Where-Object { $_.Status -eq "InProgress" } | Measure-Object).count -ne 0) {
        Write-Host "Pipeline run status: In Progress" -foregroundcolor "Yellow"
        Start-Sleep -Seconds 30
    }
    else {
        Write-Host "Pipeline 'SQLServerToBlobPipeline' run finished. Result:" -foregroundcolor "Yellow"
        $result
        break
    }
}

サンプル実行の出力結果を次に示します。

ResourceGroupName    : <resourceGroupName>
DataFactoryName      : <dataFactoryName>
ActivityRunId        : 24af7cf6-efca-4a95-931d-067c5c921c25
ActivityName         : CopySqlServerToAzureBlobActivity
ActivityType         : Copy
PipelineRunId        : 7b538846-fd4e-409c-99ef-2475329f5729
PipelineName         : SQLServerToBlobPipeline
Input                : {source, sink, enableStaging}
Output               : {dataRead, dataWritten, filesWritten, sourcePeakConnections...}
LinkedServiceName    :
ActivityRunStart     : 9/11/2019 7:10:37 AM
ActivityRunEnd       : 9/11/2019 7:10:58 AM
DurationInMs         : 21094
Status               : Succeeded
Error                : {errorCode, message, failureType, target}
AdditionalProperties : {[retryAttempt, ], [iterationHash, ], [userProperties, {}], [recoveryStatus, None]...}

次のコマンドを実行して、パイプライン SQLServerToBlobPipeline の実行 ID を取得し、詳細なアクティビティの実行結果をチェックすることができます。

Write-Host "Pipeline 'SQLServerToBlobPipeline' run result:" -foregroundcolor "Yellow"
($result | Where-Object {$_.ActivityName -eq "CopySqlServerToAzureBlobActivity"}).Output.ToString()

サンプル実行の出力結果を次に示します。

{  
    "dataRead":36,
    "dataWritten":32,
    "filesWritten":1,
    "sourcePeakConnections":1,
    "sinkPeakConnections":1,
    "rowsRead":2,
    "rowsCopied":2,
    "copyDuration":18,
    "throughput":0.01,
    "errors":[  

    ],
    "effectiveIntegrationRuntime":"ADFTutorialIR",
    "usedParallelCopies":1,
    "executionDetails":[  
        {  
            "source":{  
                "type":"SqlServer"
            },
            "sink":{  
                "type":"AzureBlobStorage",
                "region":"CentralUS"
            },
            "status":"Succeeded",
            "start":"2019-09-11T07:10:38.2342905Z",
            "duration":18,
            "usedParallelCopies":1,
            "detailedDurations":{  
                "queuingDuration":6,
                "timeToFirstByte":0,
                "transferDuration":5
            }
        }
    ]
}

出力を検証する

このパイプラインは、adftutorial BLOB コンテナーに対して fromonprem という名前の出力フォルダーを自動的に作成します。出力フォルダーに dbo.emp.txt ファイルがあることを確認してください。

Azure Portal の adftutorial コンテナーウィンドウで [最新の情報に更新] を選択して出力フォルダーを表示します。
フォルダーの一覧で、fromonprem を選択します。
dbo.emp.txt という名前のファイルが表示されていることを確認します。

このサンプルのパイプラインは、Azure Blob Storage 内のある場所から別の場所にデータをコピーするものです。以下の方法を学習しました。

データファクトリを作成します。
セルフホステッド統合ランタイムを作成します。
SQL Server と Azure Storage のリンクされたサービスを作成します。
SQL Server と Azure BLOB のデータセットを作成します。
コピーアクティビティでデータを移動するパイプラインを作成します。
パイプラインの実行を開始します。
パイプラインの実行を監視します。

Data Factory でサポートされるデータストアの一覧については、サポートされるデータストアに関するセクションを参照してください。

次のチュートリアルに進んで、ソースからコピー先にデータを一括コピーする方法について学習しましょう。

データを一括コピーする

次の方法で共有

チュートリアル:SQL Server データベースから Azure Blob Storage にデータをコピーする

前提条件

Azure サブスクリプション

Azure ロール

SQL Server 2014、2016、2017

Azure ストレージアカウント

ストレージアカウント名とアカウントキーの取得

adftutorial コンテナーの作成

Windows PowerShell

Azure PowerShell をインストールする

PowerShell にログインする

Data Factory の作成

自己ホスト型統合ランタイムを作成する

統合ランタイムのインストール

リンクされたサービスを作成します

Azure Storage のリンクされたサービスを作成する (コピー先/シンク)

SQL Server のリンクされたサービスを作成して暗号化する (ソース)

データセットを作成する

ソース SQL Server データベースのデータセットを作成する

Azure Blob Storage (シンク) のデータセットを作成する

パイプラインを作成する

パイプラインの実行を作成する

パイプラインの実行を監視します

出力を検証する

フィードバック

その他のリソース

次の方法で共有

チュートリアル:SQL Server データベースから Azure Blob Storage にデータをコピーする

前提条件

Azure サブスクリプション

Azure ロール

SQL Server 2014、2016、2017

Azure ストレージ アカウント

ストレージ アカウント名とアカウント キーの取得

adftutorial コンテナーの作成

Windows PowerShell

Azure PowerShell をインストールする

PowerShell にログインする

Data Factory の作成

自己ホスト型統合ランタイムを作成する

統合ランタイムのインストール

リンクされたサービスを作成します

Azure Storage のリンクされたサービスを作成する (コピー先/シンク)

SQL Server のリンクされたサービスを作成して暗号化する (ソース)

データセットを作成する

ソース SQL Server データベースのデータセットを作成する

Azure Blob Storage (シンク) のデータセットを作成する

パイプラインを作成する

パイプラインの実行を作成する

パイプラインの実行を監視します

出力を検証する

関連するコンテンツ

フィードバック

その他のリソース

Azure ストレージアカウント

ストレージアカウント名とアカウントキーの取得