AWS Lambda でリアルタイムDynamics 365 Business Central のデータにアクセス(IntelliJ IDEA を使用)
AWS Lambda は、新しい情報やイベントに素早く応答するアプリケーションを構築できるコンピューティングサービスです。CData JDBC Driver for Dynamics 365 Business Central と組み合わせることで、AWS Lambda 関数からリアルタイムDynamics 365 Business Central のデータを操作できます。この記事では、IntelliJ で Maven を使用して AWS Lambda 関数を構築し、Dynamics 365 Business Central のデータに接続してクエリを実行する方法を説明します。
最適化されたデータ処理機能を組み込んだ CData JDBC ドライバは、リアルタイムDynamics 365 Business Central のデータとのインタラクションにおいて卓越したパフォーマンスを発揮します。Dynamics 365 Business Central に対して複雑な SQL クエリを発行すると、ドライバーはフィルタや集計などのサポートされている SQL 操作を直接Dynamics 365 Business Centralにプッシュし、サポートされていない操作(主に SQL 関数や JOIN 操作)は組み込みの SQL エンジンを使用してクライアント側で処理します。さらに、動的メタデータクエリ機能により、ネイティブのデータ型を使用してDynamics 365 Business Central のデータの操作・分析が可能です。
ステップ1:接続プロパティの設定と接続文字列の構築
CData JDBC Driver for Dynamics 365 Business Central のインストーラーをダウンロードし、パッケージを解凍して JAR ファイルを実行してドライバーをインストールします。次に、必要な接続プロパティを収集します。
Dynamics 365 Business Central 接続プロパティの取得・設定方法
Dynamics 365 Business Central への認証には、User およびAccessKey プロパティが必要です。
データに接続するには、OrganizationUrl を指定します。OrganizationUrl は、 http://businesscentral.dynamics.com/abc123/ などのBusiness Central アカウントへのエンドポインであるか、Web サービスのルートを参照する必要があります。OrganizationUrl を指定する方法 および利用可能なエンドポイントについての詳細は、Business Central エンドポイント を参照してください。組織内に複数の会社がある場合は、どの会社に接続するかを特定するためにCompany を指定する必要があります。 会社が1つだけの場合は、Company を指定する必要はありません。
Dynamics 365 Business Central に認証するには、User およびAccessKey 接続プロパティを指定します。Microsoft では、これらをテストおよび開発目的で推奨します。ただし、運用環境での使用は推奨していません。User およびAccessKey の値を取得するには、Dynamics 365 Business Central の「ユーザー」ページに移動して「編集」をクリックします。User Name および Web Service Access Key の値は、User およびPassword 接続文字列プロパティとして入力する値です。User Name はE メールアドレス ではありません。短縮されたユーザー名です。
Microsoft では、OAuth 認証を使用する本番ユースケースを推奨します。詳細については、ヘルプドキュメントの「OAuth 認証の使用」を参照してください。
NOTE: AWS Lambda 関数で JDBC ドライバーを使用するには、ライセンス(製品版または試用版)とランタイムキー(RTK)が必要です。ライセンス(または試用版)の取得については、弊社営業チームまでお問い合わせください。
組み込みの接続文字列デザイナー
JDBC URL の構築には、Dynamics 365 Business Central JDBC Driver に組み込まれている接続文字列デザイナーを使用できます。JAR ファイルをダブルクリックするか、コマンドラインから JAR ファイルを実行してください。
java -jar cdata.jdbc.d365businesscentral.jar
接続プロパティ(RTK を含む)を入力し、接続文字列をクリップボードにコピーします。
ステップ2:IntelliJ でプロジェクトを作成
- IntelliJ IDEA で「New Project」をクリックします。
- Generators から「Maven Archetype」を選択します。
- プロジェクトに名前を付け、Archetype として「maven.archetypes:maven-archetype-quickstart」を選択します。
- 「Create」をクリックします。
CData JDBC Driver for Dynamics 365 Business Central JAR ファイルのインストール
プロジェクトのルートフォルダから以下の Maven コマンドを実行して、JAR ファイルをプロジェクトにインストールします。
mvn install:install-file -Dfile="PATH/TO/CData JDBC Driver for Dynamics 365 Business Central 20XX/lib/cdata.jdbc.d365businesscentral.jar" -DgroupId="org.cdata.connectors" -DartifactId="cdata-d365businesscentral-connector" -Dversion="23" -Dpackaging=jar
依存関係の追加
Maven プロジェクトの pom.xml ファイル内で、AWS とCData JDBC Driver for Dynamics 365 Business Centralを依存関係として追加します(<dependencies> 要素内に以下の XML を追加)。
- AWS
<dependency> <groupId>com.amazonaws</groupId> <artifactId>aws-lambda-java-core</artifactId> <version>1.2.2</version> <!--Replace with the actual version--> </dependency>
- CData JDBC Driver for Dynamics 365 Business Central
<dependency> <groupId>org.cdata.connectors</groupId> <artifactId>cdata-d365businesscentral-connector</artifactId> <version>25</version> <!--Replace with the actual version--> </dependency>
- Fat JAR 作成用の Maven Shade Plugin
<build> <plugins> <plugin> <groupId>org.apache.maven.plugins</groupId> <artifactId>maven-shade-plugin</artifactId> <version>3.4.1</version> <executions> <execution> <phase>package</phase> <goals> <goal>shade</goal> </goals> <configuration> <createDependencyReducedPom>false</createDependencyReducedPom> <transformers> <transformer implementation="org.apache.maven.plugins.shade.resource.ManifestResourceTransformer"> <mainClass>com.example.CDataLambda</mainClass> <!-- Change to your actual Lambda handler class --> </transformer> </transformers> </configuration> </execution> </executions> </plugin> </plugins> </build>
AWS Lambda 関数の作成
このサンプルプロジェクトでは、CDataLambda.java と CDataLambdaTest.java の2つのソースファイルを作成します。
Lambda 関数の定義
- CDataLambda クラスを AWS Lambda SDK の RequestHandler インターフェースを実装するように更新します。handleRequest メソッドを追加する必要があります。このメソッドは、Lambda 関数がトリガーされたときに以下のタスクを実行します:
- 入力を使用して SQL クエリを構築
- CData JDBC Driver for Dynamics 365 Business Central を登録
- JDBC を使用してDynamics 365 Business Centralへの接続を確立
- Dynamics 365 Business Central で SQL クエリを実行
- 結果をコンソールに出力
- 出力メッセージを返す
-
以下の完全な Lambda クラスを使用してください。インポート、クラス定義、handleRequest メソッドが含まれています。DriverManager.getConnection 呼び出し内の接続文字列値は、実際の値に置き換えてください。
package com.example; import com.amazonaws.services.lambda.runtime.Context; import com.amazonaws.services.lambda.runtime.RequestHandler; import java.sql.Connection; import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.ResultSetMetaData; import java.sql.SQLException; import java.sql.Statement; public class CDataLambda implements RequestHandler < Object, String > { @Override public String handleRequest(Object input, Context context) { String query = "SELECT * FROM " + input; String bucketName = "MY_AWS_BUCKET"; try { Class.forName("cdata.jdbc.d365businesscentral.D365BusinessCentralDriver"); cdata.jdbc.d365businesscentral.D365BusinessCentralDriver driver = new cdata.jdbc.d365businesscentral.D365BusinessCentralDriver(); DriverManager.registerDriver(driver); } catch (SQLException ex) { // Registering the driver failed throw new RuntimeException("Failed to register JDBC driver", ex); } catch (ClassNotFoundException e) { // The driver class was not found in the classpath throw new RuntimeException("JDBC Driver class not found", e); } Connection connection = null; try { connection = DriverManager.getConnection("jdbc:cdata:d365businesscentral:RTK=52465...;OrganizationUrl=https://myaccount.financials.dynamics.com/;"); } catch (SQLException ex) { context.getLogger().log("Error getting connection: " + ex.getMessage()); } catch (Exception ex) { context.getLogger().log("Error: " + ex.getMessage()); } if (connection != null) { context.getLogger().log("Connected Successfully! "); } ResultSet resultSet = null; try { //executing query Statement stmt = connection.createStatement(); resultSet = stmt.executeQuery(query); ResultSetMetaData metaData = resultSet.getMetaData(); int numCols = metaData.getColumnCount(); //printing the results while (resultSet.next()) { for (int i = 1; i <= numCols; i++) { System.out.printf("%-25s", (resultSet.getObject(i) != null) ? resultSet.getObject(i).toString().replaceAll(" ", "") : null); } System.out.print(" "); } } catch (SQLException ex) { System.out.println("SQL Exception: " + ex.getMessage()); } catch (Exception ex) { System.out.println("General exception: " + ex.getMessage()); } return "v24 query: " + query + " complete"; } }
ステップ3:Lambda 関数のデプロイと実行
IntelliJ で関数をビルドしたら、Maven プロジェクト全体を単一の JAR ファイルとしてデプロイする準備が整います。
- IntelliJ で mvn install コマンドを使用して SNAPSHOT JAR ファイルをビルドします。
Note: Maven Shade Plugin は target フォルダに2つの JAR を生成します。AWS Lambda には常に、すべての必要な依存関係を含むサイズの大きい -shaded.jar ファイルをアップロードしてください。
- AWS Lambda で新しい関数を作成します(または既存の関数を開きます)。
- 関数に名前を付け、IAM ロールを選択し、タイムアウト値を関数が完了するのに十分な値に設定します(クエリの結果サイズによって異なります)。
- 「Upload from」->「.zip file」をクリックし、SNAPSHOT JAR ファイルを選択します。
- 「Runtime settings」セクションで「Edit」をクリックし、Handler を handleRequest メソッドに設定します(例:package.class::handleRequest)。
- これで関数をテストできます。「Event JSON」フィールドにテーブル名を設定し、「Test」をクリックします。
無償トライアル・詳細情報
CData JDBC Driver for Dynamics 365 Business Central の30日間の無償トライアルをダウンロードして、AWS Lambda でリアルタイムDynamics 365 Business Central のデータを活用してみてください。ご不明な点があれば、サポートチームまでお気軽にお問い合わせください。