Flex Gateway新着情報
Governance新着情報
Monitoring API Manager次の Azure Data Lake Storage Connector の例は、以下の操作方法を示しています。
これらの例では、一部の項目値に変数を使用しています。次のいずれかを実行できます。
コード内で変数を値に置き換える。
プロパティファイルで各変数の値を指定しておき、コネクタ設定からそのファイルを参照する。
プロパティプレースホルダーを使用する利点とその設定方法については、「Anypoint Connector 設定」を参照してください。
この例は、Azure Data Lake Storage のファイルシステムを作成する方法を示し、次の手順が含まれています。
必要に応じて、フローの XML をコピーして [Configuration XML (設定 XML)] タブに貼り付ける。
Studio で新しい Mule プロジェクトを作成します。
[Mule Palette (Mule パレット)] ビューで「http
」を検索し、[Listener] 操作を選択します。
[Listener] 操作を Studio キャンバスにドラッグします。
[Listener] 設定で、[Connector configuration (コネクタ設定)] 項目の横にある [+] をクリックしてグローバル要素を追加します。
デフォルトを受け入れて [OK] をクリックします。
[General (一般)] プロパティタブで、[Path (パス)] 項目を create-fs
に設定します。
[Mule Palette (Mule パレット)] ビューで「azure
」を検索し、[Azure Data Lake Storage Connector] > [Create File System] 操作を選択します。
[Create File System] 操作を [Mule Palette (Mule パレット)] から [Listener] フローにドラッグします。
操作の設定画面で、[Connector configuration (コネクタ設定)] 項目の横にあるプラス記号 (+) をクリックし、グローバル要素設定項目にアクセスします。
[General (一般)] タブの [Connection (接続)] で、設定する認証方法を選択し、すべての必須値を入力します。
[OK] をクリックします。
[General (一般)] プロパティタブの [File System (ファイルシステム)] 項目で、ファイルシステムの名前を入力します。
プロジェクトを保存します。
ブラウザーを開き、GET 要求を localhost:8081/create-fs
に送信してアプリケーションをテストします。
この例のフローをすばやく Mule アプリケーションに読み込むには、次のコードをフローの [Configuration XML (設定 XML)] タブに貼り付けます。
<?xml version="1.0" encoding="UTF-8"?>
<mule xmlns:http="http://www.mulesoft.org/schema/mule/http"
xmlns:azure-data-lake-storage="http://www.mulesoft.org/schema/mule/azure-data-lake-storage"
xmlns="http://www.mulesoft.org/schema/mule/core"
xmlns:doc="http://www.mulesoft.org/schema/mule/documentation"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="
http://www.mulesoft.org/schema/mule/http http://www.mulesoft.org/schema/mule/http/current/mule-http.xsd
http://www.mulesoft.org/schema/mule/core http://www.mulesoft.org/schema/mule/core/current/mule.xsd
http://www.mulesoft.org/schema/mule/azure-data-lake-storage http://www.mulesoft.org/schema/mule/azure-data-lake-storage/current/mule-azure-data-lake-storage.xsd">
<http:listener-config name="HTTP_Listener_config" doc:name="HTTP Listener config">
<http:listener-connection host="0.0.0.0" port="8081" />
</http:listener-config>
<azure-data-lake-storage:config name="Azure_Data_Lake_Storage_Connector_Config" doc:name="Azure Data Lake Storage Connector Config">
<azure-data-lake-storage:shared-access-signature-connection accountName="${account.name}" dnsSuffix="${dns.suffix}" sasToken="${sas.token}" />
</azure-data-lake-storage:config>
<flow name="create-file-system-flow">
<http:listener doc:name="Listener" config-ref="HTTP_Listener_config" path="create-fs"/>
<azure-data-lake-storage:create-file-system doc:name="Create File System" config-ref="Azure_Data_Lake_Storage_Connector_Config" filesystem="newfilesystem"/>
</flow>
</mule>
xml
この例は、Azure Data Lake Storage のパスを作成する方法を示し、次の手順が含まれています。
必要に応じて、フローの XML をコピーして [Configuration XML (設定 XML)] タブに貼り付ける。
次の手順に従って、設定されているホストとポートで要求を受信するたびにフローを開始するように HTTP Listener ソースを設定します。
Studio で新しい Mule プロジェクトを作成します。
[Mule Palette (Mule パレット)] ビューで「http
」を検索し、[Listener] 操作を選択します。
[Listener] 操作を Studio キャンバスにドラッグします。
[Listener] 設定で、[Connector configuration (コネクタ設定)] 項目の横にある [+] をクリックしてグローバル要素を追加します。
デフォルトを受け入れて [OK] をクリックします。
[General (一般)] プロパティタブで、[Path (パス)] 項目を create-path
に設定します。
次の手順に従って、提供された Azure Data Lake Storage ファイルシステムのファイルまたはディレクトリを作成します。
[Mule Palette (Mule パレット)] ビューで「azure
」を検索し、[Create/Rename Path] 操作を選択します。
[Create/Rename Path] 操作を Studio キャンバスから [Listener] フローにドラッグします。
[Create/Rename Path] 設定で、[Connector Configuration (コネクタ設定)] 項目の横にある [+] をクリックして接続設定を追加します。
[General (一般)] タブの [Connection (接続)] で、設定する認証方法を選択し、すべての必須値を入力します。
[OK] をクリックします。
[File System (ファイルシステム)] 項目で、対象 Azure Data Lake Storage ファイルシステムの値を入力します。
ファイルシステムが存在しない場合、エラーがスローされます。
[Path (パス)] で、任意のパス名を入力します。
[Resource (リソース)] で、「file
」または「directory
」を入力します。
プロジェクトを保存します。
GET 要求を localhost:8081/create-path
に送信して、アプリケーションをテストします。
この例のフローをすばやく Mule アプリケーションに読み込むには、次のコードをフローの [Configuration XML (設定 XML)] タブに貼り付けます。
<?xml version="1.0" encoding="UTF-8"?>
<mule xmlns:http="http://www.mulesoft.org/schema/mule/http"
xmlns:azure-data-lake-storage="http://www.mulesoft.org/schema/mule/azure-data-lake-storage"
xmlns="http://www.mulesoft.org/schema/mule/core"
xmlns:doc="http://www.mulesoft.org/schema/mule/documentation"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="
http://www.mulesoft.org/schema/mule/http http://www.mulesoft.org/schema/mule/http/current/mule-http.xsd
http://www.mulesoft.org/schema/mule/core http://www.mulesoft.org/schema/mule/core/current/mule.xsd
http://www.mulesoft.org/schema/mule/azure-data-lake-storage http://www.mulesoft.org/schema/mule/azure-data-lake-storage/current/mule-azure-data-lake-storage.xsd">
<http:listener-config name="HTTP_Listener_config" doc:name="HTTP Listener config">
<http:listener-connection host="0.0.0.0" port="8081" />
</http:listener-config>
<azure-data-lake-storage:config name="Azure_Data_Lake_Storage_Connector_Config" doc:name="Azure Data Lake Storage Connector Config">
<azure-data-lake-storage:shared-access-signature-connection accountName="${account.name}" dnsSuffix="${dns.suffix}" sasToken="${sas.token}" />
</azure-data-lake-storage:config>
<flow name="create-path-flow">
<http:listener doc:name="Listener" config-ref="HTTP_Listener_config" path="create-path"/>
<azure-data-lake-storage:create-or-rename doc:name="Create/Rename Path" config-ref="Azure_Data_Lake_Storage_Connector_Config" fileSystem="newfilesystem" path="newpath" resource="directory"/>
</flow>
</mule>
xml
この例では、2 つの Update Path 操作を設定します。
最初の Update Path 操作は、Azure Data Lake Storage ファイルシステムの既存のファイルにコンテンツを追加するために append を使用して設定されます。
これを行うには、最初にアプリケーションをセットアップし、File Connector の Read 操作を追加し、Set Variable コンポーネントを設定し、append を使用して Update Path 操作を設定します。
2 つ目の Update Path 操作は、Azure Data Lake Storage ファイルシステムの既存のファイルのコンテンツをフラッシュするために flush を使用して設定されます。
次の手順に従って、設定されているホストとポートで要求を受信するたびにフローを開始するように HTTP Listener ソースを設定します。
Studio で新しい Mule プロジェクトを作成します。
[Mule Palette (Mule パレット)] ビューで「http
」を検索し、[Listener] 操作を選択します。
[Listener] 操作を Studio キャンバスにドラッグします。
[Listener] 設定で、[Connector configuration (コネクタ設定)] 項目の横にある [+] をクリックしてグローバル要素を追加します。
デフォルトを受け入れて [OK] をクリックします。
[General (一般)] プロパティタブで、[Path (パス)] 項目を update-path
に設定します。
プロジェクトに File Connector を追加し、Azure Data Lake Storage ファイルシステムのファイルを読み取るように Read 操作を設定します。
[Mule Palette (Mule パレット)] ビューで、[(X) Search in Exchange ((X) Exchange 内を検索)] をクリックします。
[Add Modules to Project (モジュールをプロジェクトに追加)] で、検索項目に「file connector
」と入力します。
[Available modules (使用可能なモジュール)] で [File Connector] をクリックします。
[Add (追加)] をクリックします。
[Finish (完了)] をクリックします。
[Mule Palette (Mule パレット)] ビューで [File] > [Read] を選択し、[Read] 操作をフローにドラッグします。
[Read] 操作の [General (一般)] プロパティタブで、[Connector Configuration (コネクタ設定)] 項目の横にある [+] をクリックして接続設定を追加します。
値を入力して [OK] をクリックします。
[Read] 操作の [General (一般)] プロパティで、[File Path (ファイルパス)] にファイルアップロードへの絶対パスを入力します。
変数を保存して後でフローで使用するように Set Variable コンポーネントを設定します。
[Mule Palette (Mule パレット)] ビューで「set variable
」を検索し、[Set Payload] を Studio キャンバスの [Read] 操作の横にドラッグします。
[General (一般)] タブで、次の値を入力します。
Name (名前)
fileSize
Value (値)
#[attributes.size]
+
これにより、次の操作でファイル変数の長さが短縮されます。
ファイルにコンテンツを追加できるように、append を含めて Update Path 操作を設定します。
[Mule Palette (Mule パレット)] ビューで「azure
」を検索し、[Azure Data Lake Storage Connector] の [Update Path] 操作を選択します。
[Create File System] 操作を [Mule Palette (Mule パレット)] ビューから [Listener] フローの [Set Variable] コンポーネントの横にドラッグします。
[Update Path] の [General (一般)] 設定プロパティペインで、操作の接続設定を選択します。
[General (一般)] プロパティタブで、次の値を入力します。
File System (ファイルシステム)
対象 Azure Data Lake Storage ファイルシステムの値
Path (パス)
対象パスの値
Action (アクション)
append
Position (位置)
0
Content Length (コンテンツの長さ)
#[vars.fileSize]
Content (コンテンツ)
payload
プロジェクトを保存します。
ファイルのコンテンツをフラッシュできるように、flush を含めて Update Path 操作を設定します。
[Mule Palette (Mule パレット)] ビューで「azure
」を検索し、[Azure Data Lake Storage Connector] の [Update Path] 操作を選択します。
[Update Path] 操作を Studio キャンバスから append のステップで作成した [Listener] フローの [Update Path] 操作の横にドラッグします。
[Update Path] の [General (一般)] 設定プロパティペインで、操作の接続設定を選択します。
[General (一般)] プロパティタブで、次の値を入力します。
File System (ファイルシステム)
対象 Azure Data Lake Storage ファイルシステム
Path (パス)
対象パス
Action (アクション)
flush
Position (位置)
#[vars.fileSize]
Content Length (コンテンツの長さ)
0
プロジェクトを保存します。
ブラウザーを開き、GET 要求を localhost:8081/update-path
に送信してアプリケーションをテストします。
この例のフローをすばやく Mule アプリケーションに読み込むには、次のコードをフローの [Configuration XML (設定 XML)] タブに貼り付けます。
<?xml version="1.0" encoding="UTF-8"?>
<mule xmlns:file="http://www.mulesoft.org/schema/mule/file"
xmlns:http="http://www.mulesoft.org/schema/mule/http"
xmlns:azure-data-lake-storage="http://www.mulesoft.org/schema/mule/azure-data-lake-storage"
xmlns="http://www.mulesoft.org/schema/mule/core"
xmlns:doc="http://www.mulesoft.org/schema/mule/documentation"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="
http://www.mulesoft.org/schema/mule/http http://www.mulesoft.org/schema/mule/http/current/mule-http.xsd
http://www.mulesoft.org/schema/mule/core http://www.mulesoft.org/schema/mule/core/current/mule.xsd
http://www.mulesoft.org/schema/mule/azure-data-lake-storage http://www.mulesoft.org/schema/mule/azure-data-lake-storage/current/mule-azure-data-lake-storage.xsd
http://www.mulesoft.org/schema/mule/file http://www.mulesoft.org/schema/mule/file/current/mule-file.xsd">
<http:listener-config name="HTTP_Listener_config" doc:name="HTTP Listener config">
<http:listener-connection host="0.0.0.0" port="8081" />
</http:listener-config>
<azure-data-lake-storage:config name="Azure_Data_Lake_Storage_Connector_Config" doc:name="Azure Data Lake Storage Connector Config">
<azure-data-lake-storage:shared-access-signature-connection accountName="${account.name}" dnsSuffix="${dns.suffix}" sasToken="${sas.token}" />
</azure-data-lake-storage:config>
<file:config name="File_Config" doc:name="File Config"/>
<flow name="create-path-flow">
<http:listener doc:name="Listener" config-ref="HTTP_Listener_config" path="update-path"/>
<file:read doc:name="Read" config-ref="File_Config" path="${file.path}"/>
<set-variable value="#[attributes.size]" doc:name="Set Variable" variableName="fileSize"/>
<azure-data-lake-storage:update-path doc:name="Update Path" config-ref="Azure_Data_Lake_Storage_Connector_Config" fileSystem="${filesystem.name}" path="${path.name}" action="append" position="0" contentLength="#[vars.fileSize]"/>
<azure-data-lake-storage:update-path doc:name="Update Path" config-ref="Azure_Data_Lake_Storage_Connector_Config" fileSystem="${filesystem.name}" path="${path.name}" action="flush" position="#[vars.fileSize]" contentLength="0"/>
</flow>
</mule>
xml
このセクションでは、Azure Data Lake Storage Connector を使用するフローに簡単なエラー処理を実装する方法を示します。
任意のフローの [Mule Palette (Mule パレット)] ビューで [Core] > [On Error Continue] を選択し、フローの [Error Handling (エラー処理)] セクションにドラッグします。
[Mule Palette (Mule パレット)] ビューから、[Core] > [Transform Message] をフローにドラッグします。
[Mule Palette (Mule パレット)] ビューで「logger
」を検索し、[Logger] コンポーネントを [Transform Message] の右側にドラッグします。
[Logger] コンポーネントの [General (一般)] プロパティタブで、次の値を入力します。
output application/json --- error.errorMessage.payload
Azure サービスからのエラーコードにアクセスするには、次の式を使用します。
error.muleMessage.typedValue.error.code
エラーメッセージにアクセスするには、次の式を使用します。
error.muleMessage.typedValue.error.message