from redis import Redis

redis_connection = Redis(decode_responses=True, db=0)

stream_name ='testowy_strumien'

redis_connection.xadd(stream_name,{'testowy_klucz': 'testowa_wartosc'}) # dodanie do strumienia słownika
message = redis_connection.xread({stream_name: '0-0'}, block=None, count=1) #odczytanie elementów na podstawie
																		# ilości count, block ustala na ile ms 
																		#ma byc blokowane dzieki temu mozna urzywać
																		#w petli, nazwa to słownik z kluczem oraz
																		#id z któego startuje
print(message)


