Mercurial > code > home > repos > homeauto

annotate lib/twisted_sse_demo/api_example.py @ 1299:fa74a9c9f753

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
rm old golang server that made an rdf graph from inputs on rpi (goraptor & hwio) Ignore-this: 9631ad748dccd16277c74ee602846add darcs-hash:223083e3a057713de9856ce548eddd285c8f48fa
author drewp <drewp@bigasterisk.com>
date Sun, 21 Apr 2019 02:45:35 -0700
parents ee168d55524a
children
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
1156
ee168d55524a reasoning & collector move into docker images
drewp <drewp@bigasterisk.com>
parents:
diff changeset
1 import time
ee168d55524a reasoning & collector move into docker images
drewp <drewp@bigasterisk.com>
parents:
diff changeset
2
ee168d55524a reasoning & collector move into docker images
drewp <drewp@bigasterisk.com>
parents:
diff changeset
3 from eventsource import EventSource
ee168d55524a reasoning & collector move into docker images
drewp <drewp@bigasterisk.com>
parents:
diff changeset
4
ee168d55524a reasoning & collector move into docker images
drewp <drewp@bigasterisk.com>
parents:
diff changeset
5 EVENTSOURCE_URL = 'http://localhost:12000/subscribe'
ee168d55524a reasoning & collector move into docker images
drewp <drewp@bigasterisk.com>
parents:
diff changeset
6
ee168d55524a reasoning & collector move into docker images
drewp <drewp@bigasterisk.com>
parents:
diff changeset
7 def onmessage(data):
ee168d55524a reasoning & collector move into docker images
drewp <drewp@bigasterisk.com>
parents:
diff changeset
8 print 'Got payload with data %s' % data
ee168d55524a reasoning & collector move into docker images
drewp <drewp@bigasterisk.com>
parents:
diff changeset
9
ee168d55524a reasoning & collector move into docker images
drewp <drewp@bigasterisk.com>
parents:
diff changeset
10 if __name__ == '__main__':
ee168d55524a reasoning & collector move into docker images
drewp <drewp@bigasterisk.com>
parents:
diff changeset
11 eventSource = EventSource(EVENTSOURCE_URL)
ee168d55524a reasoning & collector move into docker images
drewp <drewp@bigasterisk.com>
parents:
diff changeset
12 eventSource.onmessage(onmessage, callInThread=True)
ee168d55524a reasoning & collector move into docker images
drewp <drewp@bigasterisk.com>
parents:
diff changeset
13 time.sleep(20)