Data ontvangen via ZeroMQ
61 views
Skip to first unread message
Hessel
Apr 12, 2024, 7:59:35 AMApr 12
to openov
Hoi allemaal,
Ik probeer te verbinden met het NDOV-loket maar het wil nog niet lukken. Ik heb mijn ip-adres doorgegeven en krijg via de volgende link: http://pubsub.ndovloket.nl/ een klokje te zien, wat mij doet vermoeden dat ik het adres kan bereiken.
Ik probeer via de code in de bijlage de data op te halen. Heeft iemand tips in wat ik misschien fout doe?
Alvast bedankt,
Hessel
Stefan de Konink
Apr 12, 2024, 10:15:19 AMApr 12
to ope...@googlegroups.com
Dit is mijn eigen test script in Python3. Werkt dat wel voor je? Je kunt
dan direct de niet-besteffort variant testen. Kijken we daarna wel of
het aan Java ligt.
#!/usr/bin/env python3
from gzip import GzipFile
from io import BytesIO
import zmq
import time
context = zmq.Context()
subscriber = context.socket(zmq.SUB)
subscriber.connect("tcp://pubsub.besteffort.ndovloket.nl:7664")
subscriber.setsockopt_string(zmq.SUBSCRIBE,"/RIG/InfoPlusDVSInterface4")
while True:
multipart = subscriber.recv_multipart()
address = multipart[0]
print(address)
try:
contents = b''.join(multipart[1:])
contents = GzipFile('','r',0,BytesIO(contents)).read()
contents = contents.decode('UTF-8') # .replace('\n',
'').replace('\r', '')
# print(int(time.time()), address , contents)
print(int(time.time()), address)
except:
open('/tmp/test.xml', 'wb').write(contents)
raise
pass
subscriber.close()
cont
--
Stefan
dan direct de niet-besteffort variant testen. Kijken we daarna wel of
het aan Java ligt.
#!/usr/bin/env python3
from gzip import GzipFile
from io import BytesIO
import zmq
import time
context = zmq.Context()
subscriber = context.socket(zmq.SUB)
subscriber.connect("tcp://pubsub.besteffort.ndovloket.nl:7664")
subscriber.setsockopt_string(zmq.SUBSCRIBE,"/RIG/InfoPlusDVSInterface4")
while True:
multipart = subscriber.recv_multipart()
address = multipart[0]
print(address)
try:
contents = b''.join(multipart[1:])
contents = GzipFile('','r',0,BytesIO(contents)).read()
contents = contents.decode('UTF-8') # .replace('\n',
'').replace('\r', '')
# print(int(time.time()), address , contents)
print(int(time.time()), address)
except:
open('/tmp/test.xml', 'wb').write(contents)
raise
pass
subscriber.close()
cont
--
Stefan
Hessel
Apr 13, 2024, 3:35:45 AMApr 13
to openov
Dank voor de reactie. Het lag denk ik toch aan het ip-adres wat ik via mijn werk vpn had opgegeven. Zal wel een beperking van hun vpn zijn. Toch bedankt!
Hessel
Op vrijdag 12 april 2024 om 16:15:19 UTC+2 schreef Stefan de Konink:
Reply all
Reply to author
Forward
0 new messages