Release 0.0.1 (#14)

* add poo structure

* first system object

* add dataschema, create class from json and create json from class

* start parse file with classes

* start to work on CSV files

* add recurrence on export json (for object inherited of object) and add structure for Character

* add kill, stat for every character

* add many command like objectif command, ultimate command etc...

* export_json export only key present in data_schema of each object now

* change deads to deaths

* send message to backend

* associate main service and log analyser (launch analysis with kafka)

* refactor de Matche en Map

* refactor score_team to team_score
add event from back in service for launch log_analyser

* mise en place d'event pour une map pour la timeline

* création d'event pour la map et d'un end time pour les round

* add death and kill event

* add ultimate use

* add Dockefile and add data agglomerate for dynamic graph (in front).

rectify bug when player does'nt play same hero in all rounds

* add functional dockerfile, cfg and change docker-compose.yaml
add try catch for run in main.py

* hot-fix, add docker-compose for dev

* fix: typo

* Create LICENSE

* Update README.md

* delete file after process

---------

Co-authored-by: zat <[email protected]>
Co-authored-by: Rémi <[email protected]>
Co-authored-by: RemiSaurel <[email protected]>

Author: 3 people

.gitignore

@@ -1 +1,3 @@
-.vscode
+.vscode
+__pycache__/
+.idea/

LICENSE

@@ -1 +1,8 @@
-# datastrike-python-processing
+# Datastrike analysis processing
+
+## 🚀 Project
+This is the analysis processing part of Datastrike: an esport-oriented Overwatch tool.
+
+## 🧑‍💻 Credits
+- [ZaT](https://github.com/orgs/DataStrike/people/Zat-Code)
+- [Rémi](https://github.com/RemiSaurel)

README.md

@@ -0,0 +1,3 @@
+FROM python:3.11-bullseye
+ADD requirements.txt /app/requirements.txt
+RUN python3 -m pip install -r /app/requirements.txt

deploy/Dockerfile

@@ -0,0 +1,3 @@
+[kafka]
+
+url = kafka:9092

deploy/datastrike_python_processing.cfg

@@ -6,7 +6,7 @@ services:
       ZOOKEEPER_CLIENT_PORT: 2181
       ZOOKEEPER_TICK_TIME: 2000
     ports:
-      - 22181:2181
+      - 22182:2181
 
   kafka:
     image: confluentinc/cp-kafka:latest
@@ -20,4 +20,20 @@ services:
       KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://kafka:9092,PLAINTEXT_HOST://localhost:29092
       KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: PLAINTEXT:PLAINTEXT,PLAINTEXT_HOST:PLAINTEXT
       KAFKA_INTER_BROKER_LISTENER_NAME: PLAINTEXT
-      KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 1
+      KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 1
+
+  datastrike-python:
+    image: datastrike/python:latest
+    build:
+      context: .
+      dockerfile: Dockerfile
+
+    command: /bin/bash -c "cd /datastrike-python/ && python3 main.py"
+    volumes:
+      - ../src/:/datastrike-python
+      - ../../map/:/map
+      - type: bind
+        source: datastrike_python_processing.cfg
+        target: /datastrike-python/datastrike_python_processing.cfg
+    depends_on:
+      - kafka

deploy/docker-compose.yaml

@@ -1 +1,2 @@
-kafka-python==2.0.2
+kafka-python==2.0.2
+pandas==2.1.4

deploy/requirements.txt

@@ -0,0 +1,23 @@
+version: '2'
+services:
+  zookeeper:
+    image: confluentinc/cp-zookeeper:latest
+    environment:
+      ZOOKEEPER_CLIENT_PORT: 2181
+      ZOOKEEPER_TICK_TIME: 2000
+    ports:
+      - 22182:2181
+  
+  kafka:
+    image: confluentinc/cp-kafka:latest
+    depends_on:
+      - zookeeper
+    ports:
+      - 29092:29092
+    environment:
+      KAFKA_BROKER_ID: 1
+      KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
+      KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://kafka:9092,PLAINTEXT_HOST://localhost:29092
+      KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: PLAINTEXT:PLAINTEXT,PLAINTEXT_HOST:PLAINTEXT
+      KAFKA_INTER_BROKER_LISTENER_NAME: PLAINTEXT
+      KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 1

docker-compose.yaml

@@ -0,0 +1,3 @@
+[kafka]
+
+url = localhost:29092

src/datastrike_python_processing.cfg

@@ -18,8 +18,6 @@ def __init__(self, url, date=None, nb_try_connection=10):
         self.date = date
         self.nb_try_connection = nb_try_connection
 
-
-
         self.init_producer_ok, self.producer = self.init_producer(url)
         self.queue_sender = queue.Queue(2)