Compare commits
1 Commits
main
...
presnyakov
Author | SHA1 | Date | |
---|---|---|---|
5ff5bf22b1 |
27
presnyakova_victoria_lab_3/docker-compose.yml
Normal file
27
presnyakova_victoria_lab_3/docker-compose.yml
Normal file
@ -0,0 +1,27 @@
|
||||
version: '3.8'
|
||||
services:
|
||||
event_service:
|
||||
build:
|
||||
context: /event_service
|
||||
dockerfile: Dockerfile
|
||||
depends_on:
|
||||
- session_service
|
||||
expose:
|
||||
- 8081
|
||||
|
||||
session_service:
|
||||
build:
|
||||
context: /session_service
|
||||
dockerfile: Dockerfile
|
||||
expose:
|
||||
- 8082
|
||||
|
||||
nginx:
|
||||
image: nginx
|
||||
ports:
|
||||
- 8086:8086
|
||||
volumes:
|
||||
- ./nginx.conf:/etc/nginx/nginx.conf
|
||||
depends_on:
|
||||
- event_service
|
||||
- session_service
|
11
presnyakova_victoria_lab_3/event_service/Dockerfile
Normal file
11
presnyakova_victoria_lab_3/event_service/Dockerfile
Normal file
@ -0,0 +1,11 @@
|
||||
FROM python:3.9
|
||||
|
||||
EXPOSE 8081
|
||||
|
||||
RUN pip install Flask requests flasgger
|
||||
|
||||
WORKDIR /work
|
||||
|
||||
COPY event_service.py ./
|
||||
|
||||
CMD ["python", "event_service.py"]
|
48
presnyakova_victoria_lab_3/event_service/event_service.py
Normal file
48
presnyakova_victoria_lab_3/event_service/event_service.py
Normal file
@ -0,0 +1,48 @@
|
||||
from flask import Flask, jsonify, request, Response
|
||||
from datetime import datetime
|
||||
|
||||
app = Flask(__name__)
|
||||
|
||||
events = {0: {'id': 0, 'session': 0, 'info': '{"defects": 1}', 'dt': datetime(2024, 10, 10, 8, 0)},
|
||||
1: {'id': 1, 'session': 1, 'info': '{"defects": 1}', 'dt': datetime(2024, 10, 10, 8, 5)},
|
||||
2: {'id': 2, 'session': 0, 'info': '{"defects": 1}', 'dt': datetime(2024, 10, 10, 8, 10)},
|
||||
3: {'id': 3, 'session': 1, 'info': '{"defects": 1}', 'dt': datetime(2024, 10, 10, 8, 15)}}
|
||||
|
||||
|
||||
@app.route('/', methods=['GET', 'POST'])
|
||||
def get_all():
|
||||
if request.method == 'POST':
|
||||
dto = request.get_json()['dto']
|
||||
new_id = max(events.keys()) + 1
|
||||
events[new_id] = {
|
||||
'id': new_id,
|
||||
'session': dto['session'],
|
||||
'info': dto['info'],
|
||||
'dt': datetime.now()
|
||||
}
|
||||
return jsonify(events[new_id])
|
||||
return jsonify(events)
|
||||
|
||||
|
||||
@app.route('/<int:msg_id>', methods=['GET', 'PUT', 'DELETE'])
|
||||
def get_by_id(msg_id):
|
||||
if msg_id not in events.keys():
|
||||
return Response(status=404)
|
||||
|
||||
if request.method == 'PUT':
|
||||
dto = request.get_json()['dto']
|
||||
events[msg_id] = {
|
||||
'session': dto['session'],
|
||||
'info': dto['info'],
|
||||
'dt': datetime.now()
|
||||
}
|
||||
return events[msg_id]
|
||||
elif request.method == 'DELETE':
|
||||
events.pop(msg_id)
|
||||
return Response(status=200)
|
||||
|
||||
return jsonify(events[msg_id])
|
||||
|
||||
|
||||
if __name__ == '__main__':
|
||||
app.run(host='0.0.0.0', use_reloader=False, port=8081)
|
28
presnyakova_victoria_lab_3/nginx.conf
Normal file
28
presnyakova_victoria_lab_3/nginx.conf
Normal file
@ -0,0 +1,28 @@
|
||||
events {
|
||||
worker_connections 1024;
|
||||
}
|
||||
|
||||
http {
|
||||
server {
|
||||
listen 8086;
|
||||
listen [::]:8086;
|
||||
server_name localhost;
|
||||
|
||||
location /event_service/ {
|
||||
proxy_pass http://event_service:8081/;
|
||||
proxy_set_header Host $host;
|
||||
proxy_set_header X-Real-IP $remote_addr;
|
||||
proxy_set_header X-Forwarded-Proto $proxy_add_x_forwarded_for;
|
||||
proxy_set_header X-Forwarded-Prefix $scheme;
|
||||
}
|
||||
|
||||
location /session_service/ {
|
||||
proxy_pass http://session_service:8082/;
|
||||
proxy_set_header Host $host;
|
||||
proxy_set_header X-Real-IP $remote_addr;
|
||||
proxy_set_header X-Forwarded-Proto $proxy_add_x_forwarded_for;
|
||||
proxy_set_header X-Forwarded-Prefix $scheme;
|
||||
}
|
||||
|
||||
}
|
||||
}
|
11
presnyakova_victoria_lab_3/session_service/Dockerfile
Normal file
11
presnyakova_victoria_lab_3/session_service/Dockerfile
Normal file
@ -0,0 +1,11 @@
|
||||
FROM python:3.9
|
||||
|
||||
EXPOSE 8082
|
||||
|
||||
RUN pip install Flask requests flasgger
|
||||
|
||||
WORKDIR /work
|
||||
|
||||
COPY session_service.py ./
|
||||
|
||||
CMD ["python", "session_service.py"]
|
@ -0,0 +1,54 @@
|
||||
from flask import Flask, jsonify, request, Response
|
||||
from datetime import datetime
|
||||
|
||||
app = Flask(__name__)
|
||||
|
||||
sessions = {0: {'id': 0, 'info': '{"distance": 1}', 'dt_start': datetime(2024, 10, 10, 8, 0),
|
||||
'dt_end': datetime(2024, 10, 11, 8, 0)},
|
||||
1: {'id': 1, 'info': '{"distance": 1}', 'dt_start': datetime(2024, 10, 12, 8, 0),
|
||||
'dt_end': datetime(2024, 10, 13, 8, 0)},
|
||||
2: {'id': 2, 'info': '{"distance": 1}', 'dt_start': datetime(2024, 10, 14, 8, 0),
|
||||
'dt_end': datetime(2024, 10, 15, 8, 0)},
|
||||
3: {'id': 3, 'info': '{"distance": 1}', 'dt_start': datetime(2024, 10, 16, 8, 0),
|
||||
'dt_end': datetime(2024, 10, 17, 8, 0)},
|
||||
}
|
||||
|
||||
|
||||
@app.route('/', methods=['GET', 'POST'])
|
||||
def get_all():
|
||||
if request.method == 'POST':
|
||||
dto = request.get_json()['dto']
|
||||
new_id = max(sessions.keys()) + 1
|
||||
sessions[new_id] = {
|
||||
'id': new_id,
|
||||
'info': dto['info'],
|
||||
'dt_start': datetime.now(),
|
||||
'dt_end': datetime.now() + datetime.timedelta(days=1)
|
||||
|
||||
}
|
||||
return jsonify(sessions[new_id])
|
||||
return jsonify(sessions)
|
||||
|
||||
|
||||
@app.route('/<int:msg_id>', methods=['GET', 'PUT', 'DELETE'])
|
||||
def get_by_id(msg_id):
|
||||
if msg_id not in sessions.keys():
|
||||
return Response(status=404)
|
||||
|
||||
if request.method == 'PUT':
|
||||
dto = request.get_json()['dto']
|
||||
sessions[msg_id] = {
|
||||
'info': dto['info'],
|
||||
'dt_start': datetime.now(),
|
||||
'dt_end': datetime.now() + datetime.timedelta(days=1)
|
||||
}
|
||||
return sessions[msg_id]
|
||||
elif request.method == 'DELETE':
|
||||
sessions.pop(msg_id)
|
||||
return Response(status=200)
|
||||
|
||||
return jsonify(sessions[msg_id])
|
||||
|
||||
|
||||
if __name__ == '__main__':
|
||||
app.run(host='0.0.0.0', use_reloader=False, port=8082)
|
Loading…
Reference in New Issue
Block a user