Публикация сообщений в теме Pubsub в Dataflow

Каков рекомендуемый способ публикации сообщений в теме Pub / Sub в Dataflow. Я работал с клиентскими API, но не думаю, что это лучший способ справиться с этим в Dataflow.

PublishResponse response = client.projects().topics()
                        .publish(fullTopicName, publishRequest)
                        .execute();

google-cloud-pubsub google-iam google-cloud-dataflow
person Radhika    schedule 12.02.2018    source источник
comment
Я публикую сообщение из App Engine.   -  person Radhika    schedule 12.02.2018

Ответы (1)


arrow_upward
2
arrow_downward

Лучший способ опубликовать сообщения в теме PubSub из задания Dataflow - использовать класс PubsubIO. Пример:

Pipeline p = Pipeline.create();

// do some transforms

p.apply("publish message", PubsubIO.write().to("pubsub/topic"));

Ссылка: PubsubIO

person Andrew Nguonly    schedule 12.02.2018
comment
Не могли бы вы сообщить мне, как лучше всего публиковать большие данные (ГБ) из AppEngine. - person Radhika; 13.02.2018
comment
@Radhika, а Dataflow вообще задействован? Лучший способ публиковать сообщения из App Engine (гибкая среда) - использовать один из поддерживаемых клиентов. Ссылка: cloud.google. com / appengine / docs / flexible / java /. - person Andrew Nguonly; 17.02.2018