Subscription Aggregator for 3x-ui Proxy Servers

Subscription Aggregator for 3x-ui Proxy Servers — это обратный прокси, который объединяет подписки с нескольких прокси-серверов, работающих на платформе 3x-ui, в одну ссылку. Проект расширяет стандартные возможности подписок 3x-ui и делает их использование более удобным.

Для чего

Платформа 3x-ui не позволяет объединить несколько серверов, как, например, Marzban. Это приложение частично решает проблему, предоставляя единую ссылку для доступа к подпискам с нескольких прокси-серверов, облегчая подключение для пользователей.

Как работает

Приложение получает запрос с subscription_id и дублирует его на сервера 3x-ui. Каждый сервер возвращает конфигурацию в виде base64 строки. Приложение декодирует полученные данные, объединяет их и снова кодирует в base64. Пользователю нужно вставить лишь один URL, ссылающийся на Nginx сервер, чтобы получить доступ ко всем конфигурациям.

Так, если отправить запрос на https://example.com/sub/test, приложение отправит соответствующие запросы на получение подписок, к примеру на https://3x-ui_server/subscription/test и https://another_server/podpiska/test. Если подписки найдены, приложение получает ответы и объединяет их, возвращая пользователю base64 строку.

Стек технологий

🐍🚀 Backend: Python + FastAPI + httpx

🌐🔒 Сервер: Nginx

🐳🛠️ Инфраструктура: Docker

Основные фичи

✅ Объединение подписок — Автоматическое извлечение данных с нескольких прокси-серверов и их объединение в одну ссылку

✅ Асинхронная работа — Использование асинхронного Python (FastAPI), а также Nginx

✅ Безопасность — Обязательное использование HTTPS и редирект с HTTP

✅ Простота развёртывания — Благодаря Docker

Исходный код

Все исходники доступны на GitHub. Далее разберём логику проекта, а именно main.py файл.

Импорт библиотек

• os для работы с переменными окружения;
• httpx для асинхронных HTTP-запросов;
• base64 для кодирования и декодирования данных соответствующего формата;
• logging для логирования ошибок;
• asyncio.gather для параллельного выполнения асинхронных задач;
• typing.Optional для аннотации, поскольку в качестве Docker-образа используется старая легковесная версия Python, в которой ещё не поддерживаются последнии фичи аннотации;
• dotenv.load_dotenv для загрузки переменных окружения;
• fastapi для создания веб-приложения и обработки запросов.

1
2
3
4
5
6
7
8

import os
import httpx
import base64
import logging
from asyncio import gather
from typing import Optional
from dotenv import load_dotenv
from fastapi import FastAPI, Response, HTTPException

Настройка логера

Здесь настраивается система логирования. В файл script_log.log записываются предупреждения и ошибки в формате {дата_и_время уровень_логирования сообщение}

1
2
3
4
5

logging.basicConfig(
    level=logging.WARNING, filename='script_log.log',
    format='%(asctime)s %(levelname)s: %(message)s'
)
logger = logging.getLogger(__name__)

Инициализация FastAPI

Первая строка создаёт экземпляр веб-приложения, а вторая загружает переменные окружения из файла .env.

1
2

app = FastAPI()
load_dotenv()

Функция fetch_subscription

Отправляет асинхронный GET-запрос к sub_url/sub_id. В случае успешного ответа декодирует base64 в бинарный формат, иначе — возвращает None и записывает ошибку в логи.

1
2
3
4
5
6
7
8
9

async def fetch_subscription(client, sub_url: str, sub_id: str) -> Optional[bytes]:
    try:
        sub = await client.get(f'{sub_url}{sub_id}', timeout=5)
        sub.raise_for_status()
        return base64.b64decode(sub.text)
    except httpx.HTTPError as e:
            logger.error(f"Can't get subscription url from {sub_url}{sub_id}: {str(e)}")
    except ValueError as e:
            logger.error(f"Can't decode base64 for {sub_url}{sub_id}: {str(e)}")

Функция merge_subscriptions

1. Получает список URL из переменной окружения;
2. Проверяет наличие хотя бы одного сервера;
3. Создаёт асинхронный клиент;
4. Параллельно запрашивает подписки со всех серверов;
5. Фильтрует результаты, чтобы убрать неудачные запросы;
6. Объединяет и кодирует данные;
7. Возвращает ответ в виде голого текста.

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22

@app.get('/sub/{sub_id}')
async def merge_subscriptions(sub_id: str) -> Response:
    sub_urls = os.getenv('SUB_URLS').split()
    
    if not sub_urls:
        logger.error("Servers not found")
        raise HTTPException(status_code=500, detail="Servers not found")
    
    
    async with httpx.AsyncClient() as client:
        decoded_subs = [fetch_subscription(client, sub_url, sub_id) for sub_url in sub_urls]
        results = await gather(*decoded_subs)
        data = [result for result in results if result is not None]
        
        if not data:
            logger.error("No subscriptions available")
            raise HTTPException(status_code=500, detail="No subscriptions available")    
        
        merged_subs = b''.join(data)
        global_sub = base64.b64encode(merged_subs)
        
        return Response(content=global_sub, media_type='text/plain')

Установка

Процесс установки подробно описан в README.md проекта.

Ссылки

GitHub-репозиторий проекта: https://github.com/NoisyCake/3x-ui_subscriptions_aggregator#
Автор: https://t.me/noisycake
ТКГ: https://t.me/hfk_blog
Teletype: https://teletype.in/@noisycake

Лицензия

Проект распространяется под лицензией MIT. Подробности в файле LICENSE.