翻訳は機械翻訳により提供されています。提供された翻訳内容と英語版の間で齟齬、不一致または矛盾がある場合、英語版が優先します。
# ストリーミングビデオの顔検索
**注記**
ストリーミングビデオと一括イメージ分析は、新しいお客様では利用できなくなりました。詳細については、「[Amazon Rekognition 機能の可用性の変更](rekognition-availability-changes.md)」を参照してください。
**この変更は、他の Amazon Rekognition 機能の可用性には影響しません。**
Amazon Rekognition Video では、コレクション内の顔を検索し、ストリーミングビデオで検出された顔と一致する顔を見つけることができます。コレクションの詳細については、「[コレクション内での顔の検索](collections.md)」を参照してください。
**Topics**
+ [Amazon Rekognition Video 顔検索ストリームプロセッサの作成](#streaming-video-creating-stream-processor)
+ [Amazon Rekognition Video 顔検索ストリームプロセッサの起動](#streaming-video-starting-stream-processor)
+ [顔検索用ストリームプロセッサの使用 (Java V2 の例)](#using-stream-processors-v2)
+ [顔検索用ストリームプロセッサの使用 (Java V1 の例)](#using-stream-processors)
+ [ストリーミングビデオの分析結果の読み取り](streaming-video-kinesis-output.md)
+ [Kinesis Video Streams を使用した Rekognition の結果をローカルに表示する](displaying-rekognition-results-locally.md)
+ [Kinesis 顔認識 JSON フレームレコードについて](streaming-video-kinesis-output-reference.md)
次の図は、Amazon Rekognition Video がストリーミングビデオ内の顔を検出して認識する原理を示しています。
## Amazon Rekognition Video 顔検索ストリームプロセッサの作成
ストリーミングビデオを分析する前に、Amazon Rekognition Video ストリームプロセッサ ([CreateStreamProcessor](https://docs.aws.amazon.com/rekognition/latest/APIReference/API_CreateStreamProcessor.html)) を作成します。ストリームプロセッサには、Kinesis データストリームと Kinesis ビデオストリームに関する情報が含まれています。また、入力ストリーミングビデオで認識対象とする顔を含むコレクションの識別子も含まれています。ストリームプロセッサの名前も指定します。`CreateStreamProcessor` リクエストに関する JSON の例を次に示します。
```
{
"Name": "streamProcessorForCam",
"Input": {
"KinesisVideoStream": {
"Arn": "arn:aws:kinesisvideo:us-east-1:nnnnnnnnnnnn:stream/inputVideo"
}
},
"Output": {
"KinesisDataStream": {
"Arn": "arn:aws:kinesis:us-east-1:nnnnnnnnnnnn:stream/outputData"
}
},
"RoleArn": "arn:aws:iam::nnnnnnnnnnn:role/roleWithKinesisPermission",
"Settings": {
"FaceSearch": {
"CollectionId": "collection-with-100-faces",
"FaceMatchThreshold": 85.5
}
}
}
```
以下に、`CreateStreamProcessor` からのレスポンス例を示します。
```
{
“StreamProcessorArn”: “arn:aws:rekognition:us-east-1:nnnnnnnnnnnn:streamprocessor/streamProcessorForCam”
}
```
## Amazon Rekognition Video 顔検索ストリームプロセッサの起動
`CreateStreamProcessor` で指定したストリームプロセッサの名前を使用して [StartStreamProcessor](https://docs.aws.amazon.com/rekognition/latest/APIReference/API_StartStreamProcessor.html) を呼び出し、ストリーミングビデオの分析を開始します。`StartStreamProcessor` リクエストに関する JSON の例を次に示します。
```
{
"Name": "streamProcessorForCam"
}
```
ストリームプロセッサが正常に起動した場合は、空の JSON 本文と共に HTTP 200 レスポンスが返されます。
## 顔検索用ストリームプロセッサの使用 (Java V2 の例)
次のコード例は、 AWS SDK for Java バージョン 2 を使用して [CreateStreamProcessor](https://docs.aws.amazon.com/rekognition/latest/APIReference/API_CreateStreamProcessor.html) や [StartStreamProcessor](https://docs.aws.amazon.com/rekognition/latest/APIReference/API_StartStreamProcessor.html) などのさまざまなストリームプロセッサオペレーションを呼び出す方法を示しています。
このコードは、 AWS Documentation SDK サンプル GitHub リポジトリから取得されます。詳しい事例は[こちら](https://github.com/awsdocs/aws-doc-sdk-examples/blob/master/javav2/example_code/rekognition/src/main/java/com/example/rekognition/CreateStreamProcessor.java)です。
```
import software.amazon.awssdk.regions.Region;
import software.amazon.awssdk.services.rekognition.RekognitionClient;
import software.amazon.awssdk.services.rekognition.model.CreateStreamProcessorRequest;
import software.amazon.awssdk.services.rekognition.model.CreateStreamProcessorResponse;
import software.amazon.awssdk.services.rekognition.model.FaceSearchSettings;
import software.amazon.awssdk.services.rekognition.model.KinesisDataStream;
import software.amazon.awssdk.services.rekognition.model.KinesisVideoStream;
import software.amazon.awssdk.services.rekognition.model.ListStreamProcessorsRequest;
import software.amazon.awssdk.services.rekognition.model.ListStreamProcessorsResponse;
import software.amazon.awssdk.services.rekognition.model.RekognitionException;
import software.amazon.awssdk.services.rekognition.model.StreamProcessor;
import software.amazon.awssdk.services.rekognition.model.StreamProcessorInput;
import software.amazon.awssdk.services.rekognition.model.StreamProcessorSettings;
import software.amazon.awssdk.services.rekognition.model.StreamProcessorOutput;
import software.amazon.awssdk.services.rekognition.model.StartStreamProcessorRequest;
import software.amazon.awssdk.services.rekognition.model.DescribeStreamProcessorRequest;
import software.amazon.awssdk.services.rekognition.model.DescribeStreamProcessorResponse;
/**
* Before running this Java V2 code example, set up your development
* environment, including your credentials.
*
* For more information, see the following documentation topic:
*
* https://docs.aws.amazon.com/sdk-for-java/latest/developer-guide/get-started.html
*/
public class CreateStreamProcessor {
public static void main(String[] args) {
final String usage = """
Usage:
Where:
role - The ARN of the AWS Identity and Access Management (IAM) role to use. \s
kinInputStream - The ARN of the Kinesis video stream.\s
kinOutputStream - The ARN of the Kinesis data stream.\s
collectionName - The name of the collection to use that contains content. \s
StreamProcessorName - The name of the Stream Processor. \s
""";
if (args.length != 5) {
System.out.println(usage);
System.exit(1);
}
String role = args[0];
String kinInputStream = args[1];
String kinOutputStream = args[2];
String collectionName = args[3];
String streamProcessorName = args[4];
Region region = Region.US_EAST_1;
RekognitionClient rekClient = RekognitionClient.builder()
.region(region)
.build();
processCollection(rekClient, streamProcessorName, kinInputStream, kinOutputStream, collectionName,
role);
startSpecificStreamProcessor(rekClient, streamProcessorName);
listStreamProcessors(rekClient);
describeStreamProcessor(rekClient, streamProcessorName);
deleteSpecificStreamProcessor(rekClient, streamProcessorName);
}
public static void listStreamProcessors(RekognitionClient rekClient) {
ListStreamProcessorsRequest request = ListStreamProcessorsRequest.builder()
.maxResults(15)
.build();
ListStreamProcessorsResponse listStreamProcessorsResult = rekClient.listStreamProcessors(request);
for (StreamProcessor streamProcessor : listStreamProcessorsResult.streamProcessors()) {
System.out.println("StreamProcessor name - " + streamProcessor.name());
System.out.println("Status - " + streamProcessor.status());
}
}
private static void describeStreamProcessor(RekognitionClient rekClient, String StreamProcessorName) {
DescribeStreamProcessorRequest streamProcessorRequest = DescribeStreamProcessorRequest.builder()
.name(StreamProcessorName)
.build();
DescribeStreamProcessorResponse describeStreamProcessorResult = rekClient
.describeStreamProcessor(streamProcessorRequest);
System.out.println("Arn - " + describeStreamProcessorResult.streamProcessorArn());
System.out.println("Input kinesisVideo stream - "
+ describeStreamProcessorResult.input().kinesisVideoStream().arn());
System.out.println("Output kinesisData stream - "
+ describeStreamProcessorResult.output().kinesisDataStream().arn());
System.out.println("RoleArn - " + describeStreamProcessorResult.roleArn());
System.out.println(
"CollectionId - "
+ describeStreamProcessorResult.settings().faceSearch().collectionId());
System.out.println("Status - " + describeStreamProcessorResult.status());
System.out.println("Status message - " + describeStreamProcessorResult.statusMessage());
System.out.println("Creation timestamp - " + describeStreamProcessorResult.creationTimestamp());
System.out.println("Last update timestamp - " + describeStreamProcessorResult.lastUpdateTimestamp());
}
private static void startSpecificStreamProcessor(RekognitionClient rekClient, String StreamProcessorName) {
try {
StartStreamProcessorRequest streamProcessorRequest = StartStreamProcessorRequest.builder()
.name(StreamProcessorName)
.build();
rekClient.startStreamProcessor(streamProcessorRequest);
System.out.println("Stream Processor " + StreamProcessorName + " started.");
} catch (RekognitionException e) {
System.out.println(e.getMessage());
System.exit(1);
}
}
private static void processCollection(RekognitionClient rekClient, String StreamProcessorName,
String kinInputStream, String kinOutputStream, String collectionName, String role) {
try {
KinesisVideoStream videoStream = KinesisVideoStream.builder()
.arn(kinInputStream)
.build();
KinesisDataStream dataStream = KinesisDataStream.builder()
.arn(kinOutputStream)
.build();
StreamProcessorOutput processorOutput = StreamProcessorOutput.builder()
.kinesisDataStream(dataStream)
.build();
StreamProcessorInput processorInput = StreamProcessorInput.builder()
.kinesisVideoStream(videoStream)
.build();
FaceSearchSettings searchSettings = FaceSearchSettings.builder()
.faceMatchThreshold(75f)
.collectionId(collectionName)
.build();
StreamProcessorSettings processorSettings = StreamProcessorSettings.builder()
.faceSearch(searchSettings)
.build();
CreateStreamProcessorRequest processorRequest = CreateStreamProcessorRequest.builder()
.name(StreamProcessorName)
.input(processorInput)
.output(processorOutput)
.roleArn(role)
.settings(processorSettings)
.build();
CreateStreamProcessorResponse response = rekClient.createStreamProcessor(processorRequest);
System.out.println("The ARN for the newly create stream processor is "
+ response.streamProcessorArn());
} catch (RekognitionException e) {
System.out.println(e.getMessage());
System.exit(1);
}
}
private static void deleteSpecificStreamProcessor(RekognitionClient rekClient, String StreamProcessorName) {
rekClient.stopStreamProcessor(a -> a.name(StreamProcessorName));
rekClient.deleteStreamProcessor(a -> a.name(StreamProcessorName));
System.out.println("Stream Processor " + StreamProcessorName + " deleted.");
}
}
```
## 顔検索用ストリームプロセッサの使用 (Java V1 の例)
次のコード例は、Java V1 を使って、[CreateStreamProcessor](https://docs.aws.amazon.com/rekognition/latest/APIReference/API_CreateStreamProcessor.html) や [StartStreamProcessor](https://docs.aws.amazon.com/rekognition/latest/APIReference/API_StartStreamProcessor.html) など、さまざまなストリームプロセッサのオペレーションを呼び出す方法を示したものです。この例には、ストリームプロセッサのオペレーションを呼び出すメソッドを提供する、ストリームプロセッサマネージャークラス (StreamManager) が含まれています。スタータークラス (Starter) は StreamManager オブジェクトを作成し、さまざまなオペレーションを呼び出します。
**例を設定するには:**
1. Starter クラスのメンバーフィールドの値を、目的の値に設定します。
1. Starter クラス関数 `main` で、必要な関数呼び出しをコメント解除します。
### Starter クラス
```
//Copyright 2018 Amazon.com, Inc. or its affiliates. All Rights Reserved.
//PDX-License-Identifier: MIT-0 (For details, see https://github.com/awsdocs/amazon-rekognition-developer-guide/blob/master/LICENSE-SAMPLECODE.)
// Starter class. Use to create a StreamManager class
// and call stream processor operations.
package com.amazonaws.samples;
import com.amazonaws.samples.*;
public class Starter {
public static void main(String[] args) {
String streamProcessorName="Stream Processor Name";
String kinesisVideoStreamArn="Kinesis Video Stream Arn";
String kinesisDataStreamArn="Kinesis Data Stream Arn";
String roleArn="Role Arn";
String collectionId="Collection ID";
Float matchThreshold=50F;
try {
StreamManager sm= new StreamManager(streamProcessorName,
kinesisVideoStreamArn,
kinesisDataStreamArn,
roleArn,
collectionId,
matchThreshold);
//sm.createStreamProcessor();
//sm.startStreamProcessor();
//sm.deleteStreamProcessor();
//sm.deleteStreamProcessor();
//sm.stopStreamProcessor();
//sm.listStreamProcessors();
//sm.describeStreamProcessor();
}
catch(Exception e){
System.out.println(e.getMessage());
}
}
}
```
### StreamManager クラス
```
//Copyright 2018 Amazon.com, Inc. or its affiliates. All Rights Reserved.
//PDX-License-Identifier: MIT-0 (For details, see https://github.com/awsdocs/amazon-rekognition-developer-guide/blob/master/LICENSE-SAMPLECODE.)
// Stream manager class. Provides methods for calling
// Stream Processor operations.
package com.amazonaws.samples;
import com.amazonaws.services.rekognition.AmazonRekognition;
import com.amazonaws.services.rekognition.AmazonRekognitionClientBuilder;
import com.amazonaws.services.rekognition.model.CreateStreamProcessorRequest;
import com.amazonaws.services.rekognition.model.CreateStreamProcessorResult;
import com.amazonaws.services.rekognition.model.DeleteStreamProcessorRequest;
import com.amazonaws.services.rekognition.model.DeleteStreamProcessorResult;
import com.amazonaws.services.rekognition.model.DescribeStreamProcessorRequest;
import com.amazonaws.services.rekognition.model.DescribeStreamProcessorResult;
import com.amazonaws.services.rekognition.model.FaceSearchSettings;
import com.amazonaws.services.rekognition.model.KinesisDataStream;
import com.amazonaws.services.rekognition.model.KinesisVideoStream;
import com.amazonaws.services.rekognition.model.ListStreamProcessorsRequest;
import com.amazonaws.services.rekognition.model.ListStreamProcessorsResult;
import com.amazonaws.services.rekognition.model.StartStreamProcessorRequest;
import com.amazonaws.services.rekognition.model.StartStreamProcessorResult;
import com.amazonaws.services.rekognition.model.StopStreamProcessorRequest;
import com.amazonaws.services.rekognition.model.StopStreamProcessorResult;
import com.amazonaws.services.rekognition.model.StreamProcessor;
import com.amazonaws.services.rekognition.model.StreamProcessorInput;
import com.amazonaws.services.rekognition.model.StreamProcessorOutput;
import com.amazonaws.services.rekognition.model.StreamProcessorSettings;
public class StreamManager {
private String streamProcessorName;
private String kinesisVideoStreamArn;
private String kinesisDataStreamArn;
private String roleArn;
private String collectionId;
private float matchThreshold;
private AmazonRekognition rekognitionClient;
public StreamManager(String spName,
String kvStreamArn,
String kdStreamArn,
String iamRoleArn,
String collId,
Float threshold){
streamProcessorName=spName;
kinesisVideoStreamArn=kvStreamArn;
kinesisDataStreamArn=kdStreamArn;
roleArn=iamRoleArn;
collectionId=collId;
matchThreshold=threshold;
rekognitionClient=AmazonRekognitionClientBuilder.defaultClient();
}
public void createStreamProcessor() {
//Setup input parameters
KinesisVideoStream kinesisVideoStream = new KinesisVideoStream().withArn(kinesisVideoStreamArn);
StreamProcessorInput streamProcessorInput =
new StreamProcessorInput().withKinesisVideoStream(kinesisVideoStream);
KinesisDataStream kinesisDataStream = new KinesisDataStream().withArn(kinesisDataStreamArn);
StreamProcessorOutput streamProcessorOutput =
new StreamProcessorOutput().withKinesisDataStream(kinesisDataStream);
FaceSearchSettings faceSearchSettings =
new FaceSearchSettings().withCollectionId(collectionId).withFaceMatchThreshold(matchThreshold);
StreamProcessorSettings streamProcessorSettings =
new StreamProcessorSettings().withFaceSearch(faceSearchSettings);
//Create the stream processor
CreateStreamProcessorResult createStreamProcessorResult = rekognitionClient.createStreamProcessor(
new CreateStreamProcessorRequest().withInput(streamProcessorInput).withOutput(streamProcessorOutput)
.withSettings(streamProcessorSettings).withRoleArn(roleArn).withName(streamProcessorName));
//Display result
System.out.println("Stream Processor " + streamProcessorName + " created.");
System.out.println("StreamProcessorArn - " + createStreamProcessorResult.getStreamProcessorArn());
}
public void startStreamProcessor() {
StartStreamProcessorResult startStreamProcessorResult =
rekognitionClient.startStreamProcessor(new StartStreamProcessorRequest().withName(streamProcessorName));
System.out.println("Stream Processor " + streamProcessorName + " started.");
}
public void stopStreamProcessor() {
StopStreamProcessorResult stopStreamProcessorResult =
rekognitionClient.stopStreamProcessor(new StopStreamProcessorRequest().withName(streamProcessorName));
System.out.println("Stream Processor " + streamProcessorName + " stopped.");
}
public void deleteStreamProcessor() {
DeleteStreamProcessorResult deleteStreamProcessorResult = rekognitionClient
.deleteStreamProcessor(new DeleteStreamProcessorRequest().withName(streamProcessorName));
System.out.println("Stream Processor " + streamProcessorName + " deleted.");
}
public void describeStreamProcessor() {
DescribeStreamProcessorResult describeStreamProcessorResult = rekognitionClient
.describeStreamProcessor(new DescribeStreamProcessorRequest().withName(streamProcessorName));
//Display various stream processor attributes.
System.out.println("Arn - " + describeStreamProcessorResult.getStreamProcessorArn());
System.out.println("Input kinesisVideo stream - "
+ describeStreamProcessorResult.getInput().getKinesisVideoStream().getArn());
System.out.println("Output kinesisData stream - "
+ describeStreamProcessorResult.getOutput().getKinesisDataStream().getArn());
System.out.println("RoleArn - " + describeStreamProcessorResult.getRoleArn());
System.out.println(
"CollectionId - " + describeStreamProcessorResult.getSettings().getFaceSearch().getCollectionId());
System.out.println("Status - " + describeStreamProcessorResult.getStatus());
System.out.println("Status message - " + describeStreamProcessorResult.getStatusMessage());
System.out.println("Creation timestamp - " + describeStreamProcessorResult.getCreationTimestamp());
System.out.println("Last update timestamp - " + describeStreamProcessorResult.getLastUpdateTimestamp());
}
public void listStreamProcessors() {
ListStreamProcessorsResult listStreamProcessorsResult =
rekognitionClient.listStreamProcessors(new ListStreamProcessorsRequest().withMaxResults(100));
//List all stream processors (and state) returned from Rekognition
for (StreamProcessor streamProcessor : listStreamProcessorsResult.getStreamProcessors()) {
System.out.println("StreamProcessor name - " + streamProcessor.getName());
System.out.println("Status - " + streamProcessor.getStatus());
}
}
}
```