Google cloud pub/sub to Datastax Cassandra( In google cloud) -

-

i have deployed 9-node datastax cluster on google cloud.

now i've been given requirement read data queue's , load datastax on google cloud( continues streaming).

i know pub/sub can read data queue not sure whether can directly load datastax.

is possible pub/sub load data datastax on google cloud ?

i new pub/sub not sure start or how start.

thanks,

there no automatic way load data google cloud pub/sub datastax. have create subscription , write subscriber code gets messages subscription , writes them datastax. quickstart guide place start steps necessary.


Comments

Post a Comment

Popular posts from this blog

linux - Could not find a package configuration file provided by "Qt5Svg" -

-
Image
i tried install disassembler using $sudo cmake ../edb-debugger-master but it's giving me following error -- boost version: 1.58.0 -- checking module 'libgvc>=2.38.0' -- cmake error @ /usr/lib/x86_64-linux-gnu/cmake/qt5/qt5config.cmake:26 (find_package): not find package configuration file provided "qt5svg" of following names: qt5svgconfig.cmake qt5svg-config.cmake add installation prefix of "qt5svg" cmake_prefix_path or set "qt5svg_dir" directory containing 1 of above files. if "qt5svg" provides separate development package or sdk, sure has been installed. call stack (most recent call first): src/cmakelists.txt:26 (find_package) -- configuring incomplete, errors occurred! see "/home/kanna/desktop/build/cmakefiles/cmakeoutput.log". if take @ picture, can see both qt5 (dependency software) , qt5svgconfig.cmake present. then why still giving me error? i fixed problem doing 2 things. first install...
Read more

simple.odata.client - Simple OData Client Unlink -

-
Image
i have 2 entities - training , certificates. training can have 0, 1, or more certificates. cannot figure out how unlink 2 entities using simple.odata.client. able link 2 entities using following code: var client = new odataclient(odataurl); var x = odatadynamic.expression; var training = await client .for(x.trainings) .key(2382) .findentryasync(); var certificate = await client .for(x.certificates) .key(1) .findentryasync(); await client .for(x.trainings) .key(training) .linkentryasync(x.certificate, certificate); that calls function in trainingscontroller following definition: public async task<ihttpactionresult> createref([fromodatauri] int key, string navigationproperty, [frombody] uri link) that part works fine. i have tried numerous ways use simple.odata unlink entities. 1 method is: var client = new odataclient(odat...
Read more