some things done
This commit is contained in:
commit
8c3bc4f217
3
.vscode/settings.json
vendored
Normal file
3
.vscode/settings.json
vendored
Normal file
@ -0,0 +1,3 @@
|
|||||||
|
{
|
||||||
|
"python.pythonPath": "/usr/bin/python3"
|
||||||
|
}
|
3
kafka/consumer.py
Normal file
3
kafka/consumer.py
Normal file
@ -0,0 +1,3 @@
|
|||||||
|
#!/usr/bin/env python3
|
||||||
|
from datetime import datetime
|
||||||
|
|
20
kafka/docker-compose.yml
Normal file
20
kafka/docker-compose.yml
Normal file
@ -0,0 +1,20 @@
|
|||||||
|
version: "3"
|
||||||
|
services:
|
||||||
|
zookeeper:
|
||||||
|
image: 'bitnami/zookeeper:latest'
|
||||||
|
ports:
|
||||||
|
- '2181:2181'
|
||||||
|
environment:
|
||||||
|
- ALLOW_ANONYMOUS_LOGIN=yes
|
||||||
|
kafka:
|
||||||
|
image: 'bitnami/kafka:latest'
|
||||||
|
ports:
|
||||||
|
- '9092:9092'
|
||||||
|
environment:
|
||||||
|
- KAFKA_BROKER_ID=1
|
||||||
|
- KAFKA_LISTENERS=PLAINTEXT://:9092
|
||||||
|
- KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://127.0.0.1:9092
|
||||||
|
- KAFKA_ZOOKEEPER_CONNECT=zookeeper:2181
|
||||||
|
- ALLOW_PLAINTEXT_LISTENER=yes
|
||||||
|
depends_on:
|
||||||
|
- zookeeper
|
1
kafka/publisher.py
Normal file
1
kafka/publisher.py
Normal file
@ -0,0 +1 @@
|
|||||||
|
#!/usr/bin/env python3
|
28
rabbit/consumer.py
Normal file
28
rabbit/consumer.py
Normal file
@ -0,0 +1,28 @@
|
|||||||
|
#!/usr/bin/env python3
|
||||||
|
from datetime import datetime
|
||||||
|
|
||||||
|
import pika
|
||||||
|
|
||||||
|
|
||||||
|
DATETIMES=[]
|
||||||
|
|
||||||
|
|
||||||
|
def callback(ch, method, properties, body):
|
||||||
|
DATETIMES.append(datetime.now())
|
||||||
|
|
||||||
|
|
||||||
|
try:
|
||||||
|
n = 10
|
||||||
|
credentials = pika.PlainCredentials("rabbit", "rabbit")
|
||||||
|
connection = pika.BlockingConnection(pika.ConnectionParameters(host="localhost", credentials=credentials, heartbeat=0, socket_timeout=5))
|
||||||
|
channel = connection.channel()
|
||||||
|
channel.exchange_declare(exchange="test",exchange_type='direct')
|
||||||
|
queue_declare_result = channel.queue_declare(queue='testqueue', exclusive=False)
|
||||||
|
queue_name = queue_declare_result.method.queue
|
||||||
|
channel.queue_bind(exchange="test",routing_key='test', queue=queue_name)
|
||||||
|
channel.basic_qos(prefetch_count=1)
|
||||||
|
channel.basic_consume(queue=queue_name, on_message_callback=callback, auto_ack=True)
|
||||||
|
channel.start_consuming()
|
||||||
|
except Exception:
|
||||||
|
connection.close()
|
||||||
|
print(DATETIMES)
|
10
rabbit/docker-compose.yml
Normal file
10
rabbit/docker-compose.yml
Normal file
@ -0,0 +1,10 @@
|
|||||||
|
version: "3"
|
||||||
|
services:
|
||||||
|
rabbitmq:
|
||||||
|
image: rabbitmq:3-management-alpine
|
||||||
|
environment:
|
||||||
|
RABBITMQ_DEFAULT_USER: rabbit
|
||||||
|
RABBITMQ_DEFAULT_PASS: rabbit
|
||||||
|
ports:
|
||||||
|
- 5672:5672
|
||||||
|
- 15672:15672
|
13
rabbit/publisher.py
Normal file
13
rabbit/publisher.py
Normal file
@ -0,0 +1,13 @@
|
|||||||
|
#!/usr/bin/env python3
|
||||||
|
import pika
|
||||||
|
try:
|
||||||
|
n = 10
|
||||||
|
credentials = pika.PlainCredentials("rabbit", "rabbit")
|
||||||
|
connection = pika.BlockingConnection(pika.ConnectionParameters(host="localhost", credentials=credentials, heartbeat=0, socket_timeout=5))
|
||||||
|
channel = connection.channel()
|
||||||
|
channel.exchange_declare(exchange="test",exchange_type='direct')
|
||||||
|
string = "\"" + "a" * n + "\""
|
||||||
|
while True:
|
||||||
|
channel.basic_publish(exchange="test",routing_key="test",body=string.encode('UTF-8'))
|
||||||
|
except Exception:
|
||||||
|
connection.close()
|
Loading…
Reference in New Issue
Block a user