Skip to content
23 de abril de 2015 / rafaelti

Queue com Beanstalk

Objetivo

Trabalhar com mensageria com o Beanstalk e definir as primeiras queue.

Plataforma

Linux, python

Conhecimento

Linux, python

Introdução

Para escalar serviço uma ótima solução é a utilização de Queue, o Beanstalk é uma ferramenta muito versátil.

Solução

A instalação é através(muitas vezes) do gerenciador de pacotes.

Para iniciar o serviço definindo o endereço e porta

# Utilização: beanstalkd -l [ip address] -p [port #]
beanstalkd -l 127.0.0.1 -p 11301 &

Alguns comandos disponíveis

# To start the service:
service beanstalkd start

# To stop the service:
service beanstalkd stop

# To restart the service:
service beanstalkd restart

# To check the status:
service beanstalkd status

Testando o Beanstalk com python

pip install pyyaml
pip install beanstalkc

Interpretador python

rafael@ubuntu:~$ python
Python 2.7.6
[GCC 4.8.2] on linux2
Type "help", "copyright", "credits" or "license" for more information.
>>> import beanstalkc
>>> beanstalk = beanstalkc.Connection(host='localhost', port=11301)
>>> beanstalk.put('job_one')
1
>>> job = beanstalk.reserve()
>>> job
<beanstalkc.Job object at 0x7f60d28fb790>
>>> beanstalk.use('tube_a')
'tube_a'
>>> beanstalk.tubes()
['default', 'tube_a']
>>> print job.body
job_one
>>> beanstalk.tubes()
['default', 'tube_a']
>>> print job.body
job_one
>>> job.delete()
>>> print job.body
job_one
>>> print job.body

Anúncios

Deixe um comentário

Preencha os seus dados abaixo ou clique em um ícone para log in:

Logotipo do WordPress.com

Você está comentando utilizando sua conta WordPress.com. Sair / Alterar )

Imagem do Twitter

Você está comentando utilizando sua conta Twitter. Sair / Alterar )

Foto do Facebook

Você está comentando utilizando sua conta Facebook. Sair / Alterar )

Foto do Google+

Você está comentando utilizando sua conta Google+. Sair / Alterar )

Conectando a %s

%d blogueiros gostam disto: