同期ベンチマークのサンプル#

このサンプルでは、同期推論要求 API を使用してモデルのパフォーマンスを推定する方法を示します。同期推論は、レイテンシー指向のシナリオでのみ使用するのが合理的です。静的な入力形状を持つモデルがサポートされています。デモとは異なり、このサンプルには他の構成可能なコマンドライン引数がありません。サンプルのソースコードを変更して、さまざまなオプションを試してください。サンプルを使用する前に、次の要件を参照してください:

  • このサンプルは、core.read_model でサポートされるすべてのファイル形式を受け入れます。

  • サンプルは、yolo-v3-tfface-detection-0200 モデルで検証されています。

  • サンプルをビルドするには、 “サンプルの導入” ガイドのサンプル・アプリケーションのビルドセクションにある手順を参照してください。

どのように動作するか#

このサンプルは、指定されたデバイスのモデルをコンパイルし、入力データをランダムに生成して、指定された秒数の間、同期推論を複数回実行します。次に、パフォーマンス結果を処理してレポートします。

#!/usr/bin/env python3 
# -*- coding: utf-8 -*- 
# Copyright (C) 2022 Intel Corporation 
# SPDX-License-Identifier: Apache-2.0 

import logging as log 
import statistics 
import sys 
from time import perf_counter 

import numpy as np 
import openvino as ov 
from openvino.runtime import get_version 
from openvino.runtime.utils.types import get_dtype 

def fill_tensor_random(tensor): 
    dtype = get_dtype(tensor.element_type) 
    rand_min, rand_max = (0, 1) if dtype == bool else (np.iinfo(np.uint8).min, np.iinfo(np.uint8).max) 
    # np.random.uniform は high を除外します。生成するには 1 を追加します 
    if np.dtype(dtype).kind in ['i', 'u', 'b']: 
        rand_max += 1 
    rs = np.random.RandomState(np.random.MT19937(np.random.SeedSequence(0))) 
    if 0 == tensor.get_size(): 
        raise RuntimeError("Models with dynamic shapes aren't supported.Input tensors must have specific shapes before inference") 
    tensor.data[:]= rs.uniform(rand_min, rand_max, list(tensor.shape)).astype(dtype) 

def main(): 
    log.basicConfig(format='[ %(levelname)s ] %(message)s', level=log.INFO, stream=sys.stdout) 
    log.info('OpenVINO:') 
    log.info(f"{'Build ':.<39} {get_version()}") 
    device_name = 'CPU’ 
    if len(sys.argv) == 3: 
        device_name = sys.argv[2] 
    elif len(sys.argv) != 2: 
        log.info(f'Usage: {sys.argv[0]} <path_to_model> <device_name>(default: CPU)') 
        return 1 
    # レイテンシーを最適化。ほとんどのデバイスはデフォルトでレイテンシーが設定されていますが、 
    # GNA などの例外もあります 
    latency = {'PERFORMANCE_HINT': 'LATENCY'} 

    # コアを作成してそれを使用してモデルをコンパイル。 
    # CLI の 2 番目のパラメーターとして名前を指定してデバイスを選択。
    # 同期シナリオでは、openvino.runtime.InferRequest のインスタンスが 
    # 1 つしか使用されないため、複数のデバイスを使用することは無意味です 
    core = ov.Core() 
    compiled_model = core.compile_model(sys.argv[1], device_name, latency) 
    ireq = compiled_model.create_infer_request() 
    # ireq の入力データを入力 
    for model_input in compiled_model.inputs: 
        fill_tensor_random(ireq.get_tensor(model_input)) 
    # ワームアップ 
    ireq.infer() 
    # seconds_to_run 秒と少なくとも niter 反復のベンチマーク 
    seconds_to_run = 10 
    niter = 10 latencies = [] 
    start = perf_counter() 
    time_point = start time_point_to_finish = start + seconds_to_run 
    while time_point < time_point_to_finish or len(latencies) < niter: 
        ireq.infer() 
        iter_end = perf_counter() 
        latencies.append((iter_end - time_point) * 1e3) 
        time_point = iter_end 
    end = time_point 
    duration = end - start 
    # 結果をレポート 
    fps = len(latencies) / duration 
    log.info(f'Count: {len(latencies)} iterations') 
    log.info(f'Duration: {duration * 1e3:.2f} ms') 
    log.info('Latency:') 
    log.info(f' Median: {statistics.median(latencies):.2f} ms') 
    log.info(f' Average: {sum(latencies) / len(latencies):.2f} ms') 
    log.info(f' Min: {min(latencies):.2f} ms') 
    log.info(f' Max: {max(latencies):.2f} ms') 
    log.info(f'Throughput: {fps:.2f} FPS') 

if __name__ == '__main__': 
    main()
// Copyright (C) 2022 Intel Corporation 
// SPDX-License-Identifier: Apache-2.0 
// 

#include <string> 
#include <vector> 

// clang-format off 
#include "openvino/openvino.hpp" 

#include "samples/args_helper.hpp" 
#include "samples/common.hpp" 
#include "samples/latency_metrics.hpp" 
#include "samples/slog.hpp" 
// clang-format on 

using Ms = std::chrono::duration<double, std::ratio<1, 1000>>; 

int main(int argc, char* argv[]) { 
    try { 
        slog::info << "OpenVINO:" << slog::endl; 
        slog::info << ov::get_openvino_version(); 

        std::string device_name = "CPU"; 
        if (argc == 3) { 
            device_name = argv[2]; 
        } else if (argc != 2) { 
            slog::info << "Usage : " << argv[0] << " <path_to_model> <device_name>(default: CPU)" << slog::endl; 
            return EXIT_FAILURE; 
        } 
        // レイテンシーを最適化。ほとんどのデバイスはデフォルトでレイテンシーが設定されていますが、 
        // GNA などの例外もあります 
        ov::AnyMap latency{{ov::hint::performance_mode.name(), ov::hint::PerformanceMode::LATENCY}}; 

        // ov::Core を作成し、それを使用してモデルをコンパイル.。 
        // CLI の 2 番目のパラメーターとして名前を指定してデバイスを選択。 
        // 同期シナリオでは、ov::InferRequest のインスタンスが 1 つしか使用されないため、 
        // 複数のデバイスを使用するのは無意味です。 
        ov::Core core; 
        ov::CompiledModel compiled_model = core.compile_model(argv[1], device_name, latency); 
        ov::InferRequest ireq = compiled_model.create_infer_request(); 
        // ireq の入力データを入力 
        for (const ov::Output<const ov::Node>& model_input : compiled_model.inputs()) { 
            fill_tensor_random(ireq.get_tensor(model_input)); 
        } 
        // ワークアップ 
        ireq.infer(); 
        // seconds_to_run 秒と少なくとも niter 反復のベンチマーク 
        std::chrono::seconds seconds_to_run{10}; 
        size_t niter = 10; 
        std::vector<double> latencies; 
        latencies.reserve(niter); 
        auto start = std::chrono::steady_clock::now(); 
        auto time_point = start; 
        auto time_point_to_finish = start + seconds_to_run; 
        while (time_point < time_point_to_finish || latencies.size() < niter) { 
            ireq.infer(); 
            auto iter_end = std::chrono::steady_clock::now(); 
            latencies.push_back(std::chrono::duration_cast<Ms>(iter_end - time_point).count()); 
            time_point = iter_end; 
        } 
        auto end = time_point; 
        double duration = std::chrono::duration_cast<Ms>(end - start).count(); 
        // 結果をレポート 
        slog::info << "Count: " << latencies.size() << " iterations" << slog::endl << "Duration: " << duration << " ms" << slog::endl << "Latency:" << slog::endl; 
        size_t percent = 50; 
        LatencyMetrics{latencies, "", percent}.write_to_slog(); 
        slog::info << "Throughput: " << double_to_string(latencies.size() * 1000 / duration) << " FPS" << slog::endl; 
    } catch (const std::exception& ex) { 
        slog::err << ex.what() << slog::endl; 
        return EXIT_FAILURE; 
    } 
    return EXIT_SUCCESS; 
}

各サンプルの明示的な説明は、“OpenVINO™ ランタイムとアプリケーションの統合” ガイドの統合ステップセクションで確認できます。

実行する#

python sync_benchmark.py <path_to_model> <device_name>(default: CPU)
sync_benchmark <path_to_model> <device_name>(default: CPU)

サンプルを実行するにはモデルを指定する必要があります。TensorFlow Zoo、HuggingFace、TensorFlow Hub などのモデル・リポジトリーから推論タスクに固有のモデルを取得できます。

#

  1. 事前トレーニングされたモデルをダウンロードします。

  2. 以下を使用して変換できます:

    import openvino as ov 
    
    ov_model = ov.convert_model('./models/googlenet-v1') 
    # または、モデルが Python モデル・オブジェクトの場合 
    ov_model = ov.convert_model(googlenet-v1)
    ovc ./models/googlenet-v1
  3. CPUgooglenet-v1 モデルを使用してベンチマークを実行します。

    python sync_benchmark.py googlenet-v1.xml
    sync_benchmark googlenet-v1.xml

サンプルの出力#

アプリケーションはパフォーマンス結果を出力します。

[ INFO ] OpenVINO: [ INFO ] Build .................................<version> 
[ INFO ] Count: 2333 iterations 
[ INFO ] Duration: 10003.59 ms 
[ INFO ] Latency: [ INFO ] Median: 3.90 ms 
[ INFO ]     Average: 4.29 ms 
[ INFO ]     Min: 3.30 ms 
[ INFO ]     Max: 10.11 ms 
[ INFO ] Throughput: 233.22 FPS

アプリケーションはパフォーマンス結果を出力します。

[ INFO ] OpenVINO: [ INFO ] Build .................................<version> 
[ INFO ] Count: 992 iterations 
[ INFO ] Duration: 15009.8 ms 
[ INFO ] Latency: 
[ INFO ]     Median: 14.00 ms 
[ INFO ]     Average: 15.13 ms 
[ INFO ]     Min: 9.33 ms 
[ INFO ]     Max: 53.60 ms 
[ INFO ] Throughput: 66.09 FPS

関連情報#