camilofernandez73 / govee_kafka_consumer Goto Github PK

Prueba de concepto de ejecución de kafka y redis en raspberry pi. Consume mensajes generados por Govee Kafka Producer.

1. Set ENV variable

     sudo nano /etc/environment
   
     GOVEE_KAFKA_CONSUMER_ENV=production
   

2. Set Up a Virtual Environment on the Raspberry Pi:

   cd /home/pi/projects/govee_kafka_consumer/
   
   
   

3. Activate the Virtual Environment:

   source venv/bin/activate
   

4. Install Dependencies:

   pip install -r requirements.txt
   

5. Running Application:

   /home/pi/projects/govee_kafka_consumer/venv/bin/python /home/pi/projects/govee_kafka_consumer/main.py
   

Creating a systemd service one of the most robust and common ways to ensure a Python script runs at boot and restarts on failure.

1. Create a Unit File:

   Create a unit file for the service:

   sudo nano /etc/systemd/system/govee_kafka_consumer.service

2. Define the Service:

   Add the following configuration to the file. Adjust paths according to the Python script and virtual environment:

   [Unit]
   Description=Govee Kafka Consumer Service
   After=network.target
   
   [Service]
   Environment="GOVEE_KAFKA_CONSUMER_ENV=production"
   User=pi
   WorkingDirectory=/home/pi/path/to/your/script
   ExecStart=/home/pi/path/to/your/venv/bin/python path/to/your/script/main.py kafka
   Restart=always
   RestartSec=30
   
   [Install]
   WantedBy=multi-user.target
   

   • Description is a meaningful description of your service.
   • After=network.target ensures the network is available before starting your service.
   • User is the user under which the script should run.
   • WorkingDirectory where the Python script is located.
   • ExecStart full path to the Python executable in the virtual environment and the path to the script.
   • Restart=always restart the service if it fails.
   • RestartSec=30 restart after 30 seconds if it fails.

3. Enable and Start the Service:

   • Reload systemd to read the new unit file:

     sudo systemctl daemon-reload
     

   • Enable the service to start on boot:

     sudo systemctl enable govee_kafka_consumer.service
     

   • Start the service immediately:

     sudo systemctl start govee_kafka_consumer.service
     

4. Additional Commands:

   • Check status, to verify the service is running correctly:

     sudo systemctl status govee_kafka_consumer.service
     

   • Stop the service immediately:

     sudo systemctl stop govee_kafka_consumer.service
     

   • Restart: Stop and immediately start the service again:

     sudo systemctl restart  govee_kafka_consumer.service
     

   • Disable: Prevent the service from starting automatically at boot, use:

     sudo systemctl disable  govee_kafka_consumer.service
     

5. Viewing Logs

   To troubleshoot or check the output of the script:

   journalctl -u govee_kafka_consumer.service

   Use the -e option, which takes you to the end of the journal:

   journalctl -u govee_kafka_consumer.service -e