C++ で Hello World!

  1. MediaPipe Framework の動作バージョンがあることを確認します。詳しくは、 インストール手順をご覧ください。

  2. hello world のサンプルを実行するには:

    $ git clone https://github.com/google/mediapipe.git
    $ cd mediapipe
    
    $ export GLOG_logtostderr=1
    # Need bazel flag 'MEDIAPIPE_DISABLE_GPU=1' as desktop GPU is not supported currently.
    $ bazel run --define MEDIAPIPE_DISABLE_GPU=1 \
        mediapipe/examples/desktop/hello_world:hello_world
    
    # It should print 10 rows of Hello World!
    # Hello World!
    # Hello World!
    # Hello World!
    # Hello World!
    # Hello World!
    # Hello World!
    # Hello World!
    # Hello World!
    # Hello World!
    # Hello World!
    
  3. hello world の例では、シンプルな MediaPipe グラフを使用しています。 CalculatorGraphConfig proto で定義される PrintHelloWorld() 関数。

    absl::Status PrintHelloWorld() {
      // Configures a simple graph, which concatenates 2 PassThroughCalculators.
      CalculatorGraphConfig config = ParseTextProtoOrDie<CalculatorGraphConfig>(R"(
        input_stream: "in"
        output_stream: "out"
        node {
          calculator: "PassThroughCalculator"
          input_stream: "in"
          output_stream: "out1"
        }
        node {
          calculator: "PassThroughCalculator"
          input_stream: "out1"
          output_stream: "out"
        }
      )");
    

    このグラフを可視化するには、 MediaPipe Visualizer です。 以下の CalculatorGraphConfig コンテンツをビジュアライザに読み込みます。詳しくは、 ビジュアライザのヘルプについては、こちらをご覧ください。

        input_stream: "in"
        output_stream: "out"
        node {
          calculator: "PassThroughCalculator"
          input_stream: "in"
          output_stream: "out1"
        }
        node {
          calculator: "PassThroughCalculator"
          input_stream: "out1"
          output_stream: "out"
        }
    

    このグラフは 1 つのグラフ入力ストリーム(in)と 1 つのグラフ出力ストリームで構成されています (out)、2 つの PassThroughCalculator を直列接続しました。

    hello_world グラフ

  4. グラフを実行する前に、OutputStreamPoller オブジェクトが 後でグラフ出力を取得し、グラフの実行を StartRun で始まる。

    CalculatorGraph graph;
    MP_RETURN_IF_ERROR(graph.Initialize(config));
    MP_ASSIGN_OR_RETURN(OutputStreamPoller poller,
                        graph.AddOutputStreamPoller("out"));
    MP_RETURN_IF_ERROR(graph.StartRun({}));
    
  5. この例では、10 個のパケットが作成され、各パケットに文字列「Hello」が含まれる 世界一!」0、1、... 9 の範囲のタイムスタンプ値を持つ)で、 MakePacket 関数。in を使用して各パケットをグラフに追加します。 最後に入力ストリームを閉じてグラフの実行を終了します。

    for (int i = 0; i < 10; ++i) {
      MP_RETURN_IF_ERROR(graph.AddPacketToInputStream("in",
                         MakePacket<std::string>("Hello World!").At(Timestamp(i))));
    }
    MP_RETURN_IF_ERROR(graph.CloseInputStream("in"));
    
  6. この例では、OutputStreamPoller オブジェクトを使用して、10 個すべてを取得します。 取得し、各パケットから文字列の内容を取得します。 出力ログに出力します。

    mediapipe::Packet packet;
    while (poller.Next(&packet)) {
      LOG(INFO) << packet.Get<string>();
    }