バッチエンジンAPIの基本 - データのエクスポート
Liferayのヘッドレスバッチエンジンは、データのインポートやエクスポートを行うためのREST APIを提供します。 これらのサービスを呼び出して、Liferayにデータをエクスポートします。
データのエクスポート
新しいLiferay DXPインスタンスを起動し、以下を実行します。
docker run -it -m 8g -p 8080:8080 liferay/dxp:2025.q1.6-lts
http://localhost:8080 に、メールアドレス test@liferay.com とパスワード test を使用して Liferay にサインインします。 プロンプトが表示されたら、パスワードを learnに変更します。
次に、以下の手順に従います。
-
バッチエンジンAPIの基本 をダウンロードして解凍します。
curl https://resources.learn.liferay.com/examples/liferay-g4j2.zip -Ounzip liferay-g4j2.zip -
データをエクスポートするには、エクスポートするエンティティの完全修飾クラス名が必要です。
/o/apiでインストールされているAPIエクスプローラーからクラス名を取得することができます。 Schemas セクションまでスクロールダウンし、エクスポートしたいエンティティのx-class-nameフィールドをメモしておきます。 -
以下のcURLスクリプトを使用して、Liferayインスタンスからアカウントをエクスポートします。 コマンドラインで、
curlフォルダに移動します。 アカウントおよびjsonの完全修飾クラス名をパラメーターとしてExportTask_POST_ToInstance.shスクリプトを実行します。jsonパラメーターは、エクスポートされたデータのフォーマットを示します。 また、jsont、jsonl、およびcsvフォーマットもサポートしています。./ExportTask_POST_ToInstance.sh com.liferay.headless.admin.user.dto.v1_0.Account jsonJSON応答は、新規エクスポートタスクの作成を示しています。 タスクの
idに注意してください。{ "className" : "com.liferay.headless.admin.user.dto.v1_0.Account", "contentType" : "JSON", "errorMessage" : "", "executeStatus" : "INITIAL", "externalReferenceCode" : "6c5286a2-aa28-175b-041e-eacca4a54d3b", "id" : 1234, "processedItemsCount" : 0, "totalItemsCount" : 0 }重要jsontは、バッチ クライアント拡張機能と組み合わせて使用する場合、*.batch-engine-dat.jsonファイルに必要な形式です。出力形式として
jsonまたはjsonlを使用する場合、すべてのフィールドがデフォルトでエクスポートされます。 フィールドを指定するには、エクスポートするフィールドを含む追加のクエリ パラメータ (fieldNames) を指定する必要があります。 各フィールドはカンマ(,)で区切る必要があります。 エクスポート形式としてcsvを使用する場合、これは必須のクエリ パラメータです。 -
現在の
executeStatusはINITIALです。 バッチエンジンへのタスクの送信を示します。 これがCOMPLETEDになるまで待ち、データをダウンロードする必要があります。 コマンドラインで、ExportTask_GET_ById.shスクリプトを実行し、1234をエクスポートタスクのIDに置き換えます。./ExportTask_GET_ById.sh 1234{ "className" : "com.liferay.headless.admin.user.dto.v1_0.Account", "contentType" : "JSON", "endTime" : "2022-10-19T14:13:58Z", "errorMessage" : "", "executeStatus" : "COMPLETED", "externalReferenceCode" : "6c5286a2-aa28-175b-041e-eacca4a54d3b", "id" : 1234, "processedItemsCount" : 8, "startTime" : "2022-10-19T14:13:58Z", "totalItemsCount" : 8 }executeStatusがCOMPLETEDの場合、エクスポートされたデータをダウンロードすることができます。 実行されていない場合は、再度コマンドを実行し、タスクの実行が終了したことを確認します。executeStatusがFAILEDを示している場合、errorMessageフィールドで、何が問題だったかを確認します。 -
executeStatusがCOMPLETEDになったら、ExportTaskContent_GET_ById.shスクリプトを実行し、1234をエクスポートタスクのIDに置き換えて、エクスポートしたデータをダウンロードできます。./ExportTaskContent_GET_ById.sh 1234これにより、エクスポートしたデータが
.zipファイルで現在のディレクトリにダウンロードされます。 ZIPファイルを展開し、適切なアプリケーションを使用してデータを表示します。 -
また、Javaクライアントを使用してThe RESTサービスを呼び出すことができます。
curlフォルダから、javaフォルダに移動します。 ソースファイルをコンパイルします。javac -classpath .:* *.java -
ExportTask_POST_ToInstanceクラスを実行します。ableをクラスの完全修飾名に置き換えます。java -classpath .:* -DclassName=able ExportTask_POST_ToInstance例えば、
Accountのデータをエクスポートします。java -classpath .:* -DclassName=com.liferay.headless.admin.user.dto.v1_0.Account ExportTask_POST_ToInstanceJSON応答からエクスポートタスクの
idに注意してください。 -
ExportTask_GET_ByIdクラスを以下のコマンドで実行します。1234をエクスポートタスクのIDに置き換えてください。java -classpath .:* -DexportTaskId=1234 ExportTask_GET_ById -
executeStatusがCOMPLETEDを示したら、ExportTaskContent_GET_ByIdクラスを実行して、データをダウンロードできます。1234をエクスポートタスクのIDに置き換えてください。java -classpath .:* -DexportTaskId=1234 ExportTaskContent_GET_ById
cURLコマンドの検証
ExportTask_POST_ToInstance.sh スクリプトは、cURL コマンドで REST サービスを呼び出します。
curl \
"http://localhost:8080/o/headless-batch-engine/v1.0/export-task/${1}/${2}" \
--header "Content-Type: application/json" \
--request "POST" \
--user "test@liferay.com:learn"
ここでは、コマンドの引数を紹介します。
| 引数 | 説明 |
|---|---|
-H "Content-Type: application/json" | リクエストボディのフォーマットがJSONであることを示します。 |
-X POST | 指定されたエンドポイントで起動するHTTPメソッド |
"http://localhost:8080/o/headless-batch-engine/v1.0/export-task/${1}/${2}" | RESTサービスのエンドポイント |
-u "test@liferay.com:learn" | 基本的な認証情報 |
ここでは、デモのために基本的な認証を使用しています。 本番環境では、 OAuth2 を介してユーザーを認証する必要があります。 OAuth2 を使用する React アプリケーションの例については、 OAuth2 を使用してユーザーを認証する を参照してください。
Javaクラスを調べる
ExportTask_POST_ToInstance.java クラスは、 ExportTaskResource サービスを呼び出すことでデータをエクスポートします。
public static void main(String[] args) throws Exception {
ExportTaskResource.Builder builder = ExportTaskResource.builder();
ExportTaskResource exportTaskResource = builder.authentication(
"test@liferay.com", "learn"
).build();
ExportTask exportTask = exportTaskResource.postExportTask(
String.valueOf(System.getProperty("className")), "json", null, null,
null, "");
System.out.println(exportTask);
}
このクラスは、次の3行のコードのみを使用してRESTサービスを呼び出します。
| 行(省略形) | 説明 |
|---|---|
ExportTaskResource.Builder builder = ... | ExportTaskResource サービスインスタンスを生成するための Builder を取得します。 |
ExportTaskResource exportTaskResource = builder.authentication(...).build(); | 基本認証を指定し、 ExportTaskResource サービスインスタンスを生成します。 |
exportTaskResource.postExportTask(...); | exportTaskResource.postExportTask メソッドを呼び出し、post にデータを渡します。 |
プロジェクトには、依存関係としてcom.liferay.headless.batch.engine.client.jarファイルが含まれていることに注意してください。 すべてのRESTアプリケーションのクライアントJAR依存関係情報は、/o/apiでインストール先のAPIエクスプローラーで確認できます。
main メソッドのコメントは、クラスを実行する方法を示しています。
他の例のJavaクラスはこれと似ていますが、異なる ExportTaskResource メソッドを呼び出します。
サービスの詳細については、 ExportTaskResource を参照してください。
以下は、cURLとJavaを使用して他のBatch Engine export RESTサービスを呼び出す例です。
ExportTaskのステータスを取得する
以下のcURLまたはJavaコマンドを実行することで、エクスポートタスクのステータスを取得することができます。 1234 をエクスポートタスクのIDに置き換えてください。
ExportTask_GET_ById.sh
コマンド:
./ExportTask_GET_ById.sh 1234
コード:
curl \
"http://localhost:8080/o/headless-batch-engine/v1.0/export-task/${1}" \
--user "test@liferay.com:learn"
ExportTask_GET_ById.java
ExportTask_GET_ById クラスを実行します。 1234 をエクスポートタスクのIDに置き換えてください。
コマンド:
java -classpath .:* -DexportTaskId=1234 ExportTask_GET_ById
コード:
public static void main(String[] args) throws Exception {
ExportTaskResource.Builder builder = ExportTaskResource.builder();
ExportTaskResource exportTaskResource = builder.authentication(
"test@liferay.com", "learn"
).build();
System.out.println(
exportTaskResource.getExportTask(
Long.valueOf(System.getProperty("exportTaskId"))));
}
データをサイトからエクスポートする
以下のcURLまたはJavaコマンドを実行して、サイトからデータをエクスポートできます。 以下の例では、あるサイトからブログ記事をエクスポートしています。 サイトの ID を見つけて、 1234 をそれに置き換えます。 別のエンティティを使用する場合は、cURLスクリプトの完全修飾クラス名パラメーターも更新する必要があります。
Liferay DXP 2025.Q3以降では、サイトIDの代わりにサイトのキー(デフォルト言語でのサイト名)または 外部参照コード を使用することもできます。
ExportTask_POST_ToSite.sh
コマンド:
./ExportTask_POST_ToSite.sh com.liferay.headless.delivery.dto.v1_0.BlogPosting json 1234
コード:
curl \
"http://localhost:8080/o/headless-batch-engine/v1.0/export-task/${1}/${2}?siteId=${3}" \
--header "Content-Type: application/json" \
--request "POST" \
--user "test@liferay.com:learn"
ExportTask_POST_ToSite.java
ExportTask_POST_ToSite クラスを実行します。 1234 をサイトのIDに、 able をエクスポートしたいクラスの完全修飾名に置き換えてください。
java -classpath .:* -DsiteId=1234 -DclassName=able ExportTask_POST_ToSite
例えば、 BlogPosting のデータをエクスポートします:
java -classpath .:* -DsiteId=1234 -DclassName=com.liferay.headless.delivery.dto.v1_0.BlogPosting ExportTask_POST_ToSite
コード:
public static void main(String[] args) throws Exception {
ExportTaskResource.Builder builder = ExportTaskResource.builder();
ExportTaskResource exportTaskResource = builder.authentication(
"test@liferay.com", "learn"
).parameter(
"siteId", String.valueOf(System.getProperty("siteId"))
).build();
ExportTask exportTask = exportTaskResource.postExportTask(
String.valueOf(System.getProperty("className")), "json", null, null,
null, "");
System.out.println(exportTask);
}
2 番目のパラメータは json であり、エクスポートされたデータの出力形式を示します。 ここでは、 jsonl と csv も使用できます。 CSVを使用する場合は、エクスポートするフィールドをカンマ区切りの文字列として指定し、それを exportTaskResource.postExportTask() メソッドの5番目のパラメータとして渡すことが必須です。
JSON応答には、新しく作成されたエクスポートタスクの情報が表示されます。 idに注意して、そのexecuteStatusを追跡します。 完了後、ExportTaskContent_GET_ById.[java|sh]をエクスポートタスクIDで実行し、データをダウンロードできます。
データエクスポートのフィルタリング
バッチエクスポートのデータをフィルタリングするには、URL の末尾に検索語句とともに フィルタ パラメータを含めます。
例えば、このバッチコマンドは、タイトル Able でフィルタリングされたブログ投稿をエクスポートします (クエリ headline eq 'Able' を使用)。
curl \
"http://localhost:8080/o/headless-batch-engine/v1.0/export-task/com.liferay.headless.delivery.dto.v1_0.BlogPosting/json?filter=headline%20eq%20%27Able%27" \
--header "Content-Type: application/json" \
--request "POST" \
--user "test@liferay.com:learn"
カスタムオブジェクトをフィルター付きでエクスポートするには、Liferay DXP 2025.Q1+/Portal GA132+が必要です。 カスタムオブジェクトを指定するには、 フィルター パラメーターと taskItemDelegateName パラメーターの両方を含めることを忘れないでください。
カスタムオブジェクトのエクスポート
カスタムオブジェクトエントリをエクスポートするには、URLに ObjectEntry クラス名を指定し、クエリパラメータ taskItemDelegateName にオブジェクト名を渡す必要があります。 例えば、このコマンドはインスタンススコープの Ableのエントリをエクスポートします。
curl \
"http://localhost:8080/o/headless-batch-engine/v1.0/export-task/com.liferay.object.rest.dto.v1_0.ObjectEntry/json?taskItemDelegateName=C_Able" \
--header "Content-Type: application/json" \
--request "POST" \
--user "test@liferay.com:learn"
権限付きでオブジェクトをエクスポートする
Liferay DXP 2025.Q1+/Portal GA132+
カスタムオブジェクト(および変更可能なシステムオブジェクト)は、 権限 フィールドで割り当てられた権限のリストとともにエクスポートできます。 各オブジェクトとともに権限をエクスポートすることを指示するには、URL のオプションの batchNestedFields パラメータに値 permissions を追加します。
エクスポートされる各オブジェクトの権限は、次のような JSON 文字列で指定されます (デフォルト):
{
"actionIds":
["DELETE","PERMISSIONS","UPDATE","VIEW"],
"roleName": "Owner"
}
例えば、このコマンドは batchNestedFields パラメーターを使用して、インスタンススコープの Able オブジェクトのエントリとその権限をエクスポートします。
curl \
"http://localhost:8080/o/headless-batch-engine/v1.0/export-task/com.liferay.object.rest.dto.v1_0.ObjectEntry/json?taskItemDelegateName=C_Able&batchNestedFields=permissions" \
--header "Content-Type: application/json" \
--request "POST" \
--user "test@liferay.com:learn"
その後、ダウンロードしたデータもインポートすることができ、インポートされたオブジェクト・エントリーは割り当てられたパーミッションを維持します。
権限付きでエクスポートされたオブジェクトエントリをインポートする場合、ターゲットインスタンスにそれぞれのエントリに対して同じロールが含まれていないと、インポート時にエラーが発生します。
エクスポートデータの内容を取得する
エクスポートしたデータは、以下のcURLコマンドとJavaコマンドでダウンロードできます。 1234 をエクスポートタスクのIDに置き換えてください。 そして、現在のディレクトリに .zip ファイルとしてダウンロードされます。
ExportTaskContent_GET_ById.sh
コマンド:
./ExportTaskContent_GET_ById.sh 1234
コード:
curl \
"http://localhost:8080/o/headless-batch-engine/v1.0/export-task/${1}/content" \
--output file.zip \
--user "test@liferay.com:learn"
ExportTaskContent_GET_ById.java
コマンド
java -classpath .:* -DexportTaskId=1234 ExportTaskContent_GET_ById
コード:
public static void main(String[] args) throws Exception {
ExportTaskResource.Builder builder = ExportTaskResource.builder();
ExportTaskResource exportTaskResource = builder.authentication(
"test@liferay.com", "learn"
).build();
HttpInvoker.HttpResponse httpResponse =
exportTaskResource.getExportTaskContentHttpResponse(
Long.valueOf(System.getProperty("exportTaskId")));
try (FileOutputStream fileOutputStream = new FileOutputStream(
"file.zip")) {
fileOutputStream.write(httpResponse.getBinaryContent());
}
}
API Explorer には、すべての Headless Batch Engine サービスとスキーマが一覧表示され、各サービスを試すためのインターフェースがあります。