Change Details

#! /usr/bin/python from __future__ import print_function from datetime import datetime import code import signal import sys from sseclient import SSEClient as EventSource TIMEOUT = 60 def on_timeout(signum, frame): print('[{}] Timeout on RC'.format( datetime.now().isoformat()), file=sys.stderr) signal.signal(signal.SIGALRM, on_timeout) signal.alarm(TIMEOUT) def on_interactreq(signum, frame): code.interact(local=globals()) signal.signal(signal.SIGUSR1, on_interactreq) for event in EventSource( 'https://stream.wikimedia.org/v2/stream/recentchange'): signal.alarm(TIMEOUT) print(datetime.now().isoformat(), end='\r')

#! /usr/bin/python from __future__ import print_function from datetime import datetime import code import signal import sys from sseclient import SSEClient TIMEOUT = 60 def on_timeout(signum, frame): print('[{}] Timeout on RC'.format( datetime.now().isoformat()), file=sys.stderr) signal.signal(signal.SIGALRM, on_timeout) signal.alarm(TIMEOUT) def on_interactreq(signum, frame): code.interact(local=globals()) signal.signal(signal.SIGUSR1, on_interactreq) client = SSEClient('https://stream.wikimedia.org/v2/stream/recentchange') for event in client: signal.alarm(TIMEOUT) print(datetime.now().isoformat(), end='\r')

#! /usr/bin/python from __future__ import print_function from datetime import datetime import code import signal import sys from sseclient import SSEClient as EventSource TIMEOUT = 60 def on_timeout(signum, frame): print('[{}] Timeout on RC'.format( datetime.now().isoformat()), file=sys.stderr) signal.signal(signal.SIGALRM, on_timeout) signal.alarm(TIMEOUT) def on_interactreq(signum, frame): code.interact(local=globals()) signal.signal(signal.SIGUSR1, on_interactreq) for event in EventSource(client = SSEClient('https://stream.wikimedia.org/v2/stream/recentchange') 'https://stream.wikimedia.org/v2/stream/recentchange'):for event in client: signal.alarm(TIMEOUT) print(datetime.now().isoformat(), end='\r')