Re: [atlas] broken atlas streams
Hi Chris, Yes, it seems to work again. https://bit.org/network/d/mmmxK8Gmk/ipv4-packetloss-to-bit?orgId=1&refresh=5s (one of our public tools using RIPE Atlas data) is showing measurements again. Thanks! Teun On 4 Mar 2022, at 13:27, Chris Amin wrote: Hi Teun, I found a possible cause of the issue and have deployed a fix. Could you tell me if it (continues to) work? Regards, Chris On 01/03/2022 22:35, Teun Vink wrote: Hi Chris, Thanks, we still see issues receiving measurements. I attached a stripped down version of the script we’ve been using for a number of years. The code basically sets up a stream and starts listening, printing all measurements it recieves. It has some threading left (we usually run this for a number of measurements). When starting this script and doing a tcpdump, I see nearly no data at all being received from the Atlas servers. I hope this helps, let me know if you need any additional info. Thanks! -- ripe-atlas mailing list ripe-atlas@ripe.net https://lists.ripe.net/mailman/listinfo/ripe-atlas
Re: [atlas] broken atlas streams
Hi Teun, I found a possible cause of the issue and have deployed a fix. Could you tell me if it (continues to) work? Regards, Chris On 01/03/2022 22:35, Teun Vink wrote: Hi Chris, Thanks, we still see issues receiving measurements. I attached a stripped down version of the script we’ve been using for a number of years. The code basically sets up a stream and starts listening, printing all measurements it recieves. It has some threading left (we usually run this for a number of measurements). When starting this script and doing a tcpdump, I see nearly no data at all being received from the Atlas servers. I hope this helps, let me know if you need any additional info. Thanks! -- ripe-atlas mailing list ripe-atlas@ripe.net https://lists.ripe.net/mailman/listinfo/ripe-atlas
Re: [atlas] broken atlas streams
Hi Chris, Thanks, we still see issues receiving measurements. I attached a stripped down version of the script we’ve been using for a number of years. The code basically sets up a stream and starts listening, printing all measurements it recieves. It has some threading left (we usually run this for a number of measurements). When starting this script and doing a tcpdump, I see nearly no data at all being received from the Atlas servers. I hope this helps, let me know if you need any additional info. Thanks! -- Teun Vink BIT | t...@bit.nl | +31 318 648 688 KvK: 09090351 | GPG: 0xFC8B25D6 | RIPE: TEUN-RIPE On 1 Mar 2022, at 13:03, Chris Amin wrote: Hi Teun, I know that my colleagues have been in contact with you but I'm writing here in case others are having the same issue. There were issues with the service when you sent this original mail, but I can no longer detect them and I understand you are still having the issue. If that's the case could you please send me the cousteau code you are using? Thanks, Chris On 23/02/2022 08:34, Teun Vink via ripe-atlas wrote: Hi, We’re seeing some issues with RIPE Atlas streams using the ripe.atlas.cousteau websocket library. Sockets seem to connect properly, but no data is received. tcpdumps show very little traffic. One of the already running receiver application (monitoring the exact same set of measurements) is receiving data, but any newly started daemon fails to receive data. Is there an issue on the RIPE Atlas infrastructure? Thanks, -- ripe-atlas mailing list ripe-atlas@ripe.net https://lists.ripe.net/mailman/listinfo/ripe-atlas #!/usr/bin/env python3 import sys from threading import Thread from ripe.atlas.cousteau import AtlasStream class Stream(Thread): def __init__(self, channel, stream_type, parameters): Thread.__init__(self) self.channel = channel self.stream_type = stream_type self.parameters = parameters def on_result_ping(self, ping): print(f"received: probe #{ping['prb_id']}, src: {ping['src_addr']}") def on_result_response(self, *args): """ Function that will be called every time we receive a new result. Args is a tuple, so you should use args[0] to access the real message. """ if args[0]['type'] == 'ping': self.on_result_ping(args[0]) else: try: sys.stderr.write( 'Measurement type {} not supported.\n'.format( args[0]['type'] ) ) sys.stderr.write('{}\n'.format(args[0])) except KeyError as err: sys.stderr.write( str('Unexpected key {} in result.\n'.format(err)) ) def run(self): """ Function which adds a new stream. """ sys.stdout.write("* connecting to Atlas... ") atlas_stream = AtlasStream() atlas_stream.connect() print("connected.") sys.stdout.write("binding channel... ") atlas_stream.bind_channel( self.channel, self.on_result_response, ) print("done.") sys.stdout.write("starting stream... ") atlas_stream.start_stream( stream_type=self.stream_type, **self.parameters ) print("done.") atlas_stream.timeout() atlas_stream.disconnect() def main(): thread = Stream( 'atlas_result', 'result', {'msm': 6943119}, ) thread.daemon = True thread.start() thread.join() sys.exit(0) if __name__ == '__main__': main() -- ripe-atlas mailing list ripe-atlas@ripe.net https://lists.ripe.net/mailman/listinfo/ripe-atlas
Re: [atlas] broken atlas streams
Hi Teun, I know that my colleagues have been in contact with you but I'm writing here in case others are having the same issue. There were issues with the service when you sent this original mail, but I can no longer detect them and I understand you are still having the issue. If that's the case could you please send me the cousteau code you are using? Thanks, Chris On 23/02/2022 08:34, Teun Vink via ripe-atlas wrote: Hi, We’re seeing some issues with RIPE Atlas streams using the ripe.atlas.cousteau websocket library. Sockets seem to connect properly, but no data is received. tcpdumps show very little traffic. One of the already running receiver application (monitoring the exact same set of measurements) is receiving data, but any newly started daemon fails to receive data. Is there an issue on the RIPE Atlas infrastructure? Thanks, -- ripe-atlas mailing list ripe-atlas@ripe.net https://lists.ripe.net/mailman/listinfo/ripe-atlas
[atlas] broken atlas streams
Hi, We’re seeing some issues with RIPE Atlas streams using the ripe.atlas.cousteau websocket library. Sockets seem to connect properly, but no data is received. tcpdumps show very little traffic. One of the already running receiver application (monitoring the exact same set of measurements) is receiving data, but any newly started daemon fails to receive data. Is there an issue on the RIPE Atlas infrastructure? Thanks, -- Teun Vink BIT | t...@bit.nl | +31 318 648 688 KvK: 09090351 | GPG: 0xFC8B25D6 | RIPE: TEUN-RIPE -- ripe-atlas mailing list ripe-atlas@ripe.net https://lists.ripe.net/mailman/listinfo/ripe-atlas