9084d75103
🎯 Изменения: - Документы загружаются по очереди (один за другим) - После загрузки каждого документа открывается модалка с крутилкой - SSE слушает конкретный event_type: {file_type}_processed - Модалка показывает результат распознавания с извлечёнными данными - Кнопка 'Продолжить' → переход к следующему документу - Опциональные документы можно пропустить - После обработки всех обязательных → 'Далее на Step 3' 📊 UX флоу: 1. Выбор типа события → показываются нужные документы 2. Документ 1: Выбрать файл → Загрузить → Модалка → Результат → Продолжить 3. Документ 2: Выбрать файл → Загрузить → Модалка → Результат → Продолжить 4. Документ 3 (опц): Загрузить ИЛИ Пропустить 5. Все обязательные обработаны → Далее на Step 3 🔑 Каждый документ получает свой уникальный event_type: - frontend отправляет file_type - n8n возвращает event_type = {file_type}_processed - frontend слушает этот конкретный event_type через SSE
71 lines
2.1 KiB
Python
Executable File
71 lines
2.1 KiB
Python
Executable File
#!/usr/bin/env python3
|
|
"""
|
|
Мониторинг Redis Pub/Sub для проверки прямой публикации из n8n
|
|
"""
|
|
import redis
|
|
import json
|
|
from datetime import datetime
|
|
|
|
print("=" * 60)
|
|
print("🎧 МОНИТОРИНГ REDIS PUB/SUB")
|
|
print("=" * 60)
|
|
|
|
# Подключение к Redis
|
|
r = redis.Redis(
|
|
host='crm.clientright.ru',
|
|
port=6379,
|
|
password='CRM_Redis_Pass_2025_Secure!',
|
|
decode_responses=True
|
|
)
|
|
|
|
# Проверка подключения
|
|
try:
|
|
r.ping()
|
|
print("✅ Redis подключен!")
|
|
except Exception as e:
|
|
print(f"❌ Ошибка подключения: {e}")
|
|
exit(1)
|
|
|
|
# Подписка на все каналы ocr_events:*
|
|
pubsub = r.pubsub()
|
|
pubsub.psubscribe('ocr_events:*')
|
|
|
|
print(f"📡 Слушаем каналы: ocr_events:*")
|
|
print(f"⏰ Запущено: {datetime.now().strftime('%Y-%m-%d %H:%M:%S')}")
|
|
print("-" * 60)
|
|
print("\n⏳ Ожидаю события... (Ctrl+C для выхода)\n")
|
|
|
|
# Счётчик событий
|
|
event_count = 0
|
|
|
|
try:
|
|
for message in pubsub.listen():
|
|
if message['type'] == 'pmessage':
|
|
event_count += 1
|
|
print(f"\n{'='*60}")
|
|
print(f"📢 СОБЫТИЕ #{event_count}")
|
|
print(f"⏰ Время: {datetime.now().strftime('%H:%M:%S')}")
|
|
print(f"📺 Канал: {message['channel']}")
|
|
print(f"📦 Данные:")
|
|
print("-" * 60)
|
|
|
|
try:
|
|
# Пытаемся распарсить как JSON
|
|
data = json.loads(message['data'])
|
|
print(json.dumps(data, indent=2, ensure_ascii=False))
|
|
except json.JSONDecodeError:
|
|
# Если не JSON - показываем как есть
|
|
print(message['data'])
|
|
|
|
print(f"{'='*60}\n")
|
|
|
|
except KeyboardInterrupt:
|
|
print(f"\n\n✅ Остановлено. Получено событий: {event_count}")
|
|
print(f"⏰ Завершено: {datetime.now().strftime('%Y-%m-%d %H:%M:%S')}")
|
|
finally:
|
|
pubsub.close()
|
|
r.close()
|
|
|
|
|
|
|