34
Python e Redis: Utilizando Pub/Sub
Acredito que você já tenha ouvido falar sobre o conceito de
publisher/subscriber, certo? E você sabia que o Redis possui essa comunicação nativamente?De maneira muito sucinta, vou mostar um exemplo prático e simples utilizando Redis e Python usando a comunicação
publish/subscriber.Para esse exemplo são necessárias três ferramentas instaladas na sua máquina:
Os detalhes de instalação vou pular porque esse exemplo pode ser feito em qualquer SO. Basta seguir a documentação de instalação de cada item.
Por fim, uma vez instalado o pip, vamos instalar o redis (ah, para quem não sabe, o
pip seria o npm do python) com o comando abaixo:pip3 install redisCrie um arquivo chamado
app.py e cole esse script:from redis import StrictRedis
from time import strftime, sleep
client = StrictRedis(host="localhost", port=6379)
subscriber = client.pubsub()
subscriber.psubscribe('channel_test')
while True:
messages = subscriber.get_message()
now = strftime('%d/%m/%Y:%H:%M:%S')
if messages:
print(f'{now} - {messages["data"]}')
else:
print(f'{now} - Nothing here!!!')
sleep(1)Importação do redis para o projeto (obviously) , importação de formatação de data da classe time e também o sleep, que vai fazer com que nosso while sofra uma pausa de 1 segundo em cada iteração.
from redis import StrictRedis
from time import strftime, sleepConexão com o redis
client = StrictRedis(host="localhost", port=6379)Especificando que vamos nos subscrever num canal chamado
channel_testsubscriber = client.pubsub()
subscriber.psubscribe('channel_test')Bloco while que vai ficar rodano sem parar o processo de
subscribe. Uma vez que seja publicada alguma mensagem no canal channel_test, vai ser printado no console.while True:
messages = subscriber.get_message()
now = strftime('%d/%m/%Y:%H:%M:%S')
if messages:
print(f'{now} - {messages["data"]}')
else:
print(f'{now} - Nothing here!!!')
sleep(1)Redis instalado? Tá na hora de usar esse carinha.
No terminal/prompt, rode o comando:
No terminal/prompt, rode o comando:
redis-cliSe tudo tiver ocorrido bem na instalação e o redis estiver rodando, você deve estar com o shell do redis habilitado.
Para publicar, basta digitar:
publish channel_test "um conteúdo qualquer aqui"Ah, a gente ainda não executou nosso script python. Pelo terminal, acesse o diretório de onde está nosso app.py e execute com o comando:
python app.pyScript rodando? Redis rodando? Publish realizado?
Pah, a mágica acontece ...
Pah, a mágica acontece ...
Agora exercite sua criatividade e implemente outras coisas bacanas usando
redis como publisher/subscriber e seja feliz =D =D =D34