Queue3 RabbitMQ - python RabbitMQ producer, consumer 구현 rabbit mq process """Message Queue.""" import logging import pika class MessageQueue: """ Message Queue. mq """ LOGGER = logging.getLogger(__name__) def __init__(self, name: str, url: str) -> None: """ Init. name str: queue name url str: radditMQ url with id, password "amqp://relay:relay1234@localhost/vh1" """ self.key = name self.url = url self.conn = None self.ch.. 2020. 6. 25. Rabbit MQ - message queue 간단히 RabbitMQ docker로 띄우기 install docker docker 설치 - ubuntu install rabbitmq $ sudo docker images $ sudo docker search rabbitmq $ sudo docker pull rabbitmq:management run rabbitmq $ sudo docker run -d --name rabbitmq -p 5672:5672 -p 8080:15672 --restart=unless-stopped -e RABBITMQ_DEFAULT_USER=mq -e RABBITMQ_DEFAULT_PASS=mq123 rabbitmq:management 2020. 6. 24. python 에서 redis를 메시지 queue로 사용 파이썬에서 redis를 message queue로 구현 redis class - redis_queue.py """RedisQueue class""" import redis class RedisQueue(object): """ Redis Lists are an ordered list, First In First Out Queue Redis List pushing new elements on the head (on the left) of the list. The max length of a list is 4,294,967,295 """ def __init__(self, name, max_size, **redis_kwargs): self.key = name self.max_size = max_size self.. 2020. 6. 19. 이전 1 다음
