Azure Data Factory または Synapse Analytics を使用して MariaDB からデータをコピーする

適用対象: Azure Data Factory Azure Synapse Analytics

ヒント

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

この記事では、Azure Data Factory または Synapse Analytics パイプラインでコピー アクティビティを使用して、MariaDB からデータをコピーする方法について説明します。 この記事は、コピー アクティビティの概要を示しているコピー アクティビティの概要に関する記事に基づいています。

サポートされる機能

この MariaDB コネクタでは、次の機能をサポートしています。

サポートされる機能	IR
Copy アクティビティ (ソース/-)	① ②
Lookup アクティビティ	① ②

① Azure 統合ランタイム ② セルフホステッド統合ランタイム

コピー アクティビティによってソースまたはシンクとしてサポートされているデータ ストアの一覧については、サポートされているデータ ストアに関する記事の表をご覧ください。

このサービスでは接続を有効にする組み込みのドライバーが提供されるので、このコネクタを使用してドライバーを手動でインストールする必要はありません。

このコネクタは現在、推奨される新しいドライバー バージョン v2 ではバージョン 10.x、11.x の MariaDB と、レガシ ドライバー バージョンでは 10.0 から 10.5 をサポートしています。

前提条件

データ ストアがオンプレ ミスネットワーク、Azure 仮想ネットワーク、または Amazon Virtual Private Cloud 内にある場合は、それに接続するようセルフホステッド統合ランタイムを構成する必要があります。

データ ストアがマネージド クラウド データ サービスである場合は、Azure Integration Runtime を使用できます。 ファイアウォール規則で承認されている IP にアクセスが制限されている場合は、Azure Integration Runtime の IP を許可リストに追加できます。

また、Azure Data Factory のマネージド仮想ネットワーク統合ランタイム機能を使用すれば、セルフホステッド統合ランタイムをインストールして構成しなくても、オンプレミス ネットワークにアクセスすることができます。

Data Factory によってサポートされるネットワーク セキュリティ メカニズムやオプションの詳細については、「データ アクセス戦略」を参照してください。

作業の開始

パイプラインでコピー アクティビティを実行するには、次のいずれかのツールまたは SDK を使用します。

• データ コピー ツール
• Azure ポータル
• .NET SDK
• Python SDK
• Azure PowerShell
• REST API
• Azure Resource Manager テンプレート

UI を使用して MariaDB のリンク サービスを作成する

次の手順を使用して、Azure portal UI で MariaDB のリンク サービスを作成します。

1. Azure Data Factory または Synapse ワークスペースの [管理] タブに移動し、[リンクされたサービス] を選択して、[新規] をクリックします。

   Azure Data Factory

   

   Azure Synapse

   

2. Maria を検索し、MariaDB コネクタを選択します。

   

3. サービスの詳細を構成し、接続をテストして、新しいリンク サービスを作成します。

   

コネクタの構成の詳細

次のセクションでは、MariaDB コネクタに固有の Data Factory エンティティを定義するために使用されるプロパティについて詳しく説明します。

リンクされたサービス プロパティ

推奨されるドライバー バージョンを使用する場合は、MariaDB のリンク サービスで次のプロパティがサポートされます。

プロパティ	内容	必須
type	type プロパティは、次のように設定する必要があります:MariaDB	はい
driverVersion	推奨されるドライバー バージョンを選んだときのドライバーのバージョン。 値は v2 です。	はい
サーバー	MariaDB サーバーの名前。	はい
port	MariaDB サーバーに接続するポート番号。	いいえ
database	MariaDB データベース名。	はい
username	ユーザー名。	はい
password	該当するユーザー名のパスワード。 安全に保存するには、このフィールドを SecureString としてマークします。 また、Azure Key Vault に格納されているシークレットを参照することもできます。	はい
connectVia	データ ストアに接続するために使用される統合ランタイム。 詳細については、「前提条件」セクションを参照してください。 指定されていない場合は、既定の Azure 統合ランタイムが使用されます。	いいえ

例:

{
    "name": "MariaDBLinkedService",
    "properties": {
        "type": "MariaDB",
        "typeProperties": {
            "server": "<server>",
            "port": "<port>",
            "database": "<database>",
            "username": "<username>",
            "password": {
                "type": "SecureString",
                "value": "<password>"
            },
            "driverVersion": "v2"
        },
        "connectVia": {
            "referenceName": "<name of Integration Runtime>",
            "type": "IntegrationRuntimeReference"
        }
    }
}

例: パスワードを Azure Key Vault に格納する

{
    "name": "MariaDBLinkedService",
    "properties": {
        "type": "MariaDB",
        "typeProperties": {
            "server": "<server>",
            "port": "<port>",
            "database": "<database>",
            "username": "<username>",
            "password": {
                "type": "AzureKeyVaultSecret",
                "store": {
                    "referenceName": "<Azure Key Vault linked service name>",
                    "type": "LinkedServiceReference"
                },
                "secretName": "<secretName>"
            },
            "driverVersion": "v2"
        },
        "connectVia": {
            "referenceName": "<name of Integration Runtime>",
            "type": "IntegrationRuntimeReference"
        }
    }
}

レガシ ドライバー バージョンを使った場合、次のプロパティがサポートされます。

プロパティ	内容	必須
type	type プロパティは、次のように設定する必要があります:MariaDB	はい
connectionString	MariaDB に接続するための ODBC 接続文字列。 パスワードを Azure Key Vault に格納して、接続文字列から pwd 構成をプルすることもできます。 詳細については、下記の例と、「Azure Key Vault への資格情報の格納」の記事を参照してください。	はい
connectVia	データ ストアに接続するために使用される統合ランタイム。 詳細については、「前提条件」セクションを参照してください。 指定されていない場合は、既定の Azure 統合ランタイムが使用されます。	いいえ

例:

{
    "name": "MariaDBLinkedService",
    "properties": {
        "type": "MariaDB",
        "typeProperties": {
            "connectionString": "Server=<host>;Port=<port>;Database=<database>;UID=<user name>;PWD=<password>"
        },
        "connectVia": {
            "referenceName": "<name of Integration Runtime>",
            "type": "IntegrationRuntimeReference"
        }
    }
}

データセットのプロパティ

データセットを定義するために使用できるセクションとプロパティの完全な一覧については、データセットに関する記事をご覧ください。 このセクションでは、MariaDB データセットでサポートされるプロパティの一覧を示します。

MariaDB からデータをコピーするには、データセットの type プロパティを MariaDBTable に設定します。 この種類のデータセットに追加の種類固有のプロパティはありません。

例

{
    "name": "MariaDBDataset",
    "properties": {
        "type": "MariaDBTable",
        "typeProperties": {},
        "schema": [],
        "linkedServiceName": {
            "referenceName": "<MariaDB linked service name>",
            "type": "LinkedServiceReference"
        }
    }
}

コピー アクティビティのプロパティ

アクティビティの定義に利用できるセクションとプロパティの完全な一覧については、パイプラインに関する記事を参照してください。 このセクションでは、MariaDB ソース でサポートされるプロパティの一覧を示します。

ソースとしての MariaDB

MariaDB からデータをコピーするには、コピー アクティビティのソースの種類を MariaDBSource に設定します。 コピー アクティビティの source セクションでは、次のプロパティがサポートされます。

プロパティ	内容	必須
type	コピー アクティビティのソースの type プロパティは、次のように設定する必要があります:MariaDBSource	はい
query	カスタム SQL クエリを使用してデータを読み取ります。 (例: "SELECT * FROM MyTable")。	いいえ (データセットの "tableName" が指定されている場合)

例:

"activities":[
    {
        "name": "CopyFromMariaDB",
        "type": "Copy",
        "inputs": [
            {
                "referenceName": "<MariaDB input dataset name>",
                "type": "DatasetReference"
            }
        ],
        "outputs": [
            {
                "referenceName": "<output dataset name>",
                "type": "DatasetReference"
            }
        ],
        "typeProperties": {
            "source": {
                "type": "MariaDBSource",
                "query": "SELECT * FROM MyTable"
            },
            "sink": {
                "type": "<sink type>"
            }
        }
    }
]

MariaDB のデータ型マッピング

MariaDB からデータをコピーする場合、MariaDB データ型からサービスが内部的に使用する中間データ型への次のマッピングが使用されます。 コピー アクティビティでソースのスキーマとデータ型がシンクにマッピングされるしくみについては、スキーマとデータ型のマッピングに関する記事を参照してください。

MariaDB データ型	中間サービス データ型	中間サービス データ型 (レガシ ドライバー バージョンの場合)
bigint	Int64	Int64
bigint unsigned	Decimal	Decimal
bit(1)	UInt64	Boolean
bit(M), M>1	UInt64	Byte[]
blob	Byte[]	Byte[]
bool	Boolean (TreatTinyAsBoolean=false の場合は、SByte としてマップされます。TreatTinyAsBoolean は既定で true です)	Int16
char	String	String
date	Datetime	Datetime
datetime	Datetime	Datetime
decimal	Decimal	Decimal, String
double	Double	Double
double precision	Double	Double
enum	String	String
float	Single	Single
int	Int32	Int32
int unsigned	Int64	Int64
integer	Int32	Int32
integer unsigned	Int64	Int64
JSON	String	-
long varbinary	Byte[]	Byte[]
long varchar	String	String
longblob	Byte[]	Byte[]
longtext	String	String
mediumblob	Byte[]	Byte[]
mediumint	Int32	Int32
mediumint unsigned	Int64	Int64
mediumtext	String	String
numeric	Decimal	Decimal
real	Double	Double
set	String	String
smallint	Int16	Int16
smallint unsigned	Int32	Int32
text	String	String
time	TimeSpan	TimeSpan
timestamp	Datetime	Datetime
tinyblob	Byte[]	Byte[]
tinyint	SByte	Int16
tinyint unsigned	Int16	Int16
tinytext	String	String
varchar	String	String
year	Int	Int

Lookup アクティビティのプロパティ

プロパティの詳細については、Lookup アクティビティに関するページを参照してください。

MariaDB ドライバーのバージョンをアップグレードする

MariaDB ドライバーのバージョンをアップグレードするのに役立つ手順を次に示します。

1. [リンク サービスの編集] ページの [ドライバーのバージョン] で [推奨] を選び、「リンク サービスのプロパティ」を参照してリンク サービスを構成します。

2. 最新の MariaDB リンク サービスのデータ型マッピングは、レガシ バージョンのデータ型マッピングのものとは異なります。 最新のデータ型マッピングについては、「MariaDB のデータ型マッピング」を参照してください。

3. 最新のドライバー バージョン v2 では、より多くの MariaDB バージョンがサポートされています。 詳細については、「サポートされる機能」を参照してください。

MariaDB で、推奨ドライバー バージョンを使用したときと、レガシ ドライバー バージョンを使用したときのの違い

次の表は、推奨ドライバー バージョンを使用したときとレガシ ドライバー バージョンを使用したときの、MariaDB コネクタ間のデータ型マッピングの違いを示しています。

MariaDB データ型	中間サービス データ型 (推奨ドライバー バージョンを使用)	中間サービス データ型 (レガシ ドライバー バージョンを使用)
bit(1)	UInt64	Boolean
bit(M)、M>1	UInt64	Byte[]
[bool]	Boolean	Int16
JSON	String	Byte[]

関連するコンテンツ

Copy アクティビティでソースおよびシンクとしてサポートされるデータ ストアの一覧については、サポートされるデータ ストアに関するセクションを参照してください。