Public Repository

Last pushed: 2 years ago
Short Description
C++ client for pusher.com event stream. Publishes the data to a qpid broker
Full Description

Pusher Generator

Acts as a source of data.

When started it will just start producing a stream of json events published to kafka.

Building:

docker build -t pusher-generator:latest .

Running:

docker run pusher-generator \
    -ePUSHER_QPID_HOST=127.0.0.1:12345 \
    -ePUSHER_QPID_EXCHANGE=amq.match

The bitcoin events published are json messages of the form

{"timestamp": "1462533093", "bids": [["449.49000000", "1.52465784"]], "asks": []}

if you would rather a feed of reddit posts then pass the variable PUSHER_REDDIT_FEED=true into the container
An example of the reddit feed:

{"domain":"imgur.com","banned_by":null,"media_embed":{},"subreddit":"food","selftext_html":null,"selftext":"","likes":null,"suggested_sort":null,"user_reports":[],"secure_media":null,"link_flair_text":"Image","id":"4i4mqc","from_kind":null,"gilded":0,"archived":false,"clicked":false,"report_reasons":null,"author":"Tenpurasoba","media":null,"score":1,"approved_by":null,"over_18":false,"hidden":false,"num_comments":0,"thumbnail":"default","subreddit_id":"t5_2qh55","hide_score":true,"edited":false,"link_flair_css_class":"image","author_flair_css_class":null,"downs":0,"secure_media_embed":{},"saved":false,"removal_reason":null,"stickied":false,"from":null,"is_self":false,"from_id":null,"permalink":"/r/food/comments/4i4mqc/cooled_yam_soba/","locked":false,"name":"t3_4i4mqc","created":1462561981,"url":"http://imgur.com/gallery/cZ4qPWK","author_flair_text":null,"quarantine":false,"title":"Cooled Yam Soba","created_utc":1462533181,"distinguished":null,"mod_reports":[],"visited":false,"num_reports":null,"ups":1}
Docker Pull Command
Owner
roids