مرحبًا بالجميع! في C++

يجب أن يكون لديك إصدار عملي من MediaPipe، يمكنك الاطّلاع على تعليمات التركيب.

لتشغيل مثال 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!

يستخدم مثال hello world رسمًا بيانيًا بسيطًا لـ MediaPipe في دالة PrintHelloWorld()، محدد في نموذج CalculatorGraphConfig.

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 من خلال لصق محتوى SketchGraphConfig أدناه في العرض المرئي. انقر هنا للحصول على مساعدة بشأن العرض المرئي.

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

يتألف هذا الرسم البياني من مصدر بيانات واحد لإدخال الرسم البياني (in) وساحة بث واحدة للإخراج للرسم البياني (out)، ومجموعتَي PassThroughCalculator متصلَين بشكل تسلسلي.

قبل تشغيل الرسم البياني، يتم توصيل كائن 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({}));

ينشئ المثال بعد ذلك 10 حزم (تحتوي كل حزمة على سلسلة "Hello World!" (تحتوي كل حزمة) على سلسلة "Hello World!" (مع قيم طوابع زمنية تتراوح بين 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"));

من خلال الكائن OutputStreamPoller، يسترد المثال جميع الحزم العشر من تدفق الإخراج، ويحصل على محتوى السلسلة من كل حزمة، ويطبعه في سجل الإخراج.

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