Как раскрутить один поток данных из другого потока данных - PullRequest
Новая
       15

Как раскрутить один поток данных из другого потока данных

1 голос
/ 30 октября 2019

Требуется раскрутить задание потока данных из другого потока данных. Первый поток данных будет прослушивать тему и, основываясь на полученном сообщении, должен ускорить второй поток данных. Пытаясь реализовать его в Java. 

CloseableHttpClient client = HttpClientBuilder.create().useSystemProperties().build();          
HttpPost request = new HttpPost("https://dataflow.googleapis.com/v1b3/projects/dataflow-begining/templates:launch");
List<NameValuePair> params = new ArrayList<>();
params.add(new BasicNameValuePair("gcsPath", "gs template location")); request.setEntity(entity); HttpResponse response = client.execute(request);

У меня возникает проблема с авторизацией, когда первый поток данных пытается ускорить второй поток данных. Кто-нибудь может мне помочь, как я могу передать учетные данные Google во время HttpCall. ? Я не хочу создавать AccessToken перед каждым вызовом, возможно ли получить токен доступа из serviceAccount или где-то еще и установить токен доступа во время http-вызова.

...