Compare commits
2 Commits
bfe4b1e938
...
e2c6e61b5d
| Author | SHA1 | Date | |
|---|---|---|---|
| e2c6e61b5d | |||
| c997e49a74 |
@ -1,4 +1,4 @@
|
|||||||
FROM python:3.12.3-slim
|
FROM python:3.13.1-slim
|
||||||
LABEL authors="UdoChudo"
|
LABEL authors="UdoChudo"
|
||||||
# Установим необходимые пакеты
|
# Установим необходимые пакеты
|
||||||
RUN apt-get update && apt-get install -y \
|
RUN apt-get update && apt-get install -y \
|
||||||
|
|||||||
BIN
requirements.txt
BIN
requirements.txt
Binary file not shown.
11
telezab.py
11
telezab.py
@ -1,16 +1,11 @@
|
|||||||
import os
|
import os
|
||||||
from functools import partial
|
from functools import partial
|
||||||
from gc import callbacks
|
|
||||||
|
|
||||||
from flask import Flask, request, jsonify, render_template
|
from flask import Flask, request, jsonify, render_template
|
||||||
import schedule
|
|
||||||
from dotenv import load_dotenv
|
from dotenv import load_dotenv
|
||||||
import hashlib
|
import hashlib
|
||||||
import telebot
|
import telebot
|
||||||
from telebot import types
|
from telebot import types
|
||||||
import logging
|
import logging
|
||||||
from logging.config import dictConfig
|
|
||||||
import zipfile
|
|
||||||
from threading import Thread, Lock
|
from threading import Thread, Lock
|
||||||
import sqlite3
|
import sqlite3
|
||||||
import time
|
import time
|
||||||
@ -23,7 +18,7 @@ from concurrent.futures import ThreadPoolExecutor
|
|||||||
from pyzabbix import ZabbixAPI
|
from pyzabbix import ZabbixAPI
|
||||||
import requests
|
import requests
|
||||||
from pytz import timezone
|
from pytz import timezone
|
||||||
from datetime import datetime, timedelta
|
from datetime import datetime
|
||||||
import re
|
import re
|
||||||
import urllib.parse
|
import urllib.parse
|
||||||
|
|
||||||
@ -49,7 +44,7 @@ RABBITMQ_HOST = os.getenv('RABBITMQ_HOST', 'localhost')
|
|||||||
RABBITMQ_QUEUE = 'telegram_notifications'
|
RABBITMQ_QUEUE = 'telegram_notifications'
|
||||||
RABBITMQ_LOGIN = os.getenv('RABBITMQ_LOGIN')
|
RABBITMQ_LOGIN = os.getenv('RABBITMQ_LOGIN')
|
||||||
RABBITMQ_PASS = os.getenv('RABBITMQ_PASS')
|
RABBITMQ_PASS = os.getenv('RABBITMQ_PASS')
|
||||||
RABBITMQ_URL = "amqp://"+ RABBITMQ_LOGIN + ":" + RABBITMQ_PASS + "@" + RABBITMQ_HOST +"/" # Замените на ваш URL RabbitMQ
|
RABBITMQ_URL_FULL = f"amqp://{RABBITMQ_LOGIN}:{RABBITMQ_PASS}@{RABBITMQ_HOST}/"
|
||||||
# Инициализируем класс RegionApi
|
# Инициализируем класс RegionApi
|
||||||
region_api = RegionAPI(DB_PATH)
|
region_api = RegionAPI(DB_PATH)
|
||||||
# Инициализируем класс UserStateManager
|
# Инициализируем класс UserStateManager
|
||||||
@ -869,7 +864,7 @@ async def consume_from_queue():
|
|||||||
while True: # Бесконечный цикл для переподключения
|
while True: # Бесконечный цикл для переподключения
|
||||||
try:
|
try:
|
||||||
# Подключение к RabbitMQ
|
# Подключение к RabbitMQ
|
||||||
connection = await aio_pika.connect_robust(RABBITMQ_URL)
|
connection = await aio_pika.connect_robust(RABBITMQ_URL_FULL)
|
||||||
async with connection:
|
async with connection:
|
||||||
# Открываем канал
|
# Открываем канал
|
||||||
channel = await connection.channel()
|
channel = await connection.channel()
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user