Как внедрить клиент gRPC в Nifi - PullRequest
Новая
       33

Как внедрить клиент gRPC в Nifi

0 голосов
/ 14 мая 2019

Я начал читать о gRPC и работаю над некоторыми проверочными концепциями реализации архитектуры на основе gRPC на основе NiFi. Требование заключается в том, что мне нужно реализовать клиент gRPC в NiFi, который будет прослушивать какой-то внешний сервер gRPC.

Чтобы начать с этого варианта использования, я создал встроенный gRPC-сервер на основе Python на моей локальной машине. Я также реализовал клиент gRPC на основе Python на удаленном компьютере и выполняю этот скрипт на языке Python с процессором «Выполнение потока» в NiFi.

Вот функции и прото файлы, которые я написал:

calculator.py 

def sum(x):
  y = x+x
  return y

calculator.proto 

syntax = "proto3";

message Number {
    float value = 1;
}

service Calculator {
    rpc Sum(Number) returns (Number) {}
}

Постановка задачи:

Я просматривал эту ссылку.

Я не понимаю, как работает InvokeGRPC. Как flowfile_service.proto принимает имя службы и атрибут, которые должны быть выполнены?

Любой образец NiFi шаблона / эталонный поток NiFi приветствуется

...