1. Вступ

У постійно мінливому ландшафті рішень для хмарного зберігання даних Cloudflare R2 з’явився як потужний конкурент, пропонуючи API, сумісний з S3, з конкурентоспроможними цінами та вражаючою продуктивністю. Ця стаття проведе вас через процес завантаження файлів до Cloudflare R2 за допомогою Python, зосереджуючись на створенні універсальної функції для повторного використання, яку можна легко інтегрувати в різні додатки.

2. Налаштування середовища

2.1 Передумови

Перш ніж перейти до реалізації, переконайтеся, що у вас є наступне:

• Python 3.7 або новішої версії, встановлений у вашій системі
• Обліковий запис Cloudflare з увімкненим R2
• Доступ до облікових даних вашого R2 бакета (ID облікового запису, ID ключа доступу та секретний ключ доступу)

2.2 Встановлення необхідних пакетів

Ми будемо використовувати бібліотеку boto3 для взаємодії з Cloudflare R2. Встановіть її за допомогою pip:

1

pip install boto3

3. Налаштування клієнта S3 для Cloudflare R2

Для взаємодії з Cloudflare R2 нам потрібно налаштувати клієнт S3 з відповідними параметрами:

 1
 2
 3
 4
 5
 6
 7
 8
 9
10

import boto3
from botocore.config import Config

s3 = boto3.client(
    "s3",
    endpoint_url="https://<accountid>.r2.cloudflarestorage.com",
    aws_access_key_id="<access_key_id>",
    aws_secret_access_key="<access_key_secret>",
    config=Config(signature_version="s3v4"),
)

3.1 Розуміння конфігурації

• endpoint_url: Це точка входу для вашого бакета Cloudflare R2. Замініть <accountid> на ваш фактичний ID облікового запису Cloudflare.
• aws_access_key_id та aws_secret_access_key: Це ваші облікові дані бакета R2. Замініть їх на ваші фактичні значення.
• config=Config(signature_version="s3v4"): Це вказує на використання версії підпису 4, яка необхідна Cloudflare R2 для аутентифікації.

4. Створення функції завантаження для повторного використання

Давайте створимо універсальну функцію, яка обробляє завантаження файлів до Cloudflare R2:

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32

import os
from typing import Optional

BUCKET_NAME = "<your_bucket_name>"
CLOUDFLARE_PUBLIC_URL = "https://<your_custom_domain>/"

def upload_to_cloudflare(file_path: str, object_name: Optional[str] = None) -> str:
    """
    Завантажити файл до Cloudflare R2, повернути публічну URL-адресу та видалити локальний файл.

    :param file_path: Шлях до файлу для завантаження
    :param object_name: Ім'я об'єкта S3. Якщо не вказано, використовується базове ім'я file_path
    :return: Публічна URL-адреса завантаженого файлу
    """
    # Якщо ім'я об'єкта S3 не вказано, використовуємо базове ім'я file_path
    if object_name is None:
        object_name = os.path.basename(file_path)

    try:
        # Завантажуємо файл
        s3.upload_file(file_path, BUCKET_NAME, object_name)
        
        # Генеруємо публічну URL-адресу для завантаженого файлу
        url = f"{CLOUDFLARE_PUBLIC_URL}{object_name}"
        
        # Видаляємо локальний файл
        os.remove(file_path)
        
        return url
    except Exception as e:
        print(f"Сталася помилка: {e}")
        return ""

4.1 Розбір функції

• Функція приймає два параметри: file_path (обов’язковий) та object_name (необов’язковий).
• Якщо object_name не надано, він за замовчуванням встановлюється як базове ім’я шляху до файлу.
• Вона завантажує файл до вказаного бакета R2 за допомогою s3.upload_file().
• Після успішного завантаження вона генерує публічну URL-адресу для файлу.
• Потім локальний файл видаляється для звільнення місця.
• Якщо під час процесу виникає будь-яка помилка, вона перехоплюється, виводиться, і повертається порожній рядок.

5. Інтеграція з FastAPI

Ось приклад того, як інтегрувати функцію upload_to_cloudflare у додаток FastAPI:

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

from fastapi import FastAPI, UploadFile, File
from fastapi.responses import JSONResponse

app = FastAPI()

@app.post("/upload")
async def upload_file(file: UploadFile = File(...)):
    # Тимчасово зберігаємо завантажений файл
    temp_file_path = f"/tmp/{file.filename}"
    with open(temp_file_path, "wb") as buffer:
        buffer.write(await file.read())
    
    # Завантажуємо до Cloudflare R2
    url = upload_to_cloudflare(temp_file_path)
    
    if url:
        return JSONResponse(content={"file_url": url}, status_code=200)
    else:
        return JSONResponse(content={"error": "Не вдалося завантажити файл"}, status_code=500)

Ця кінцева точка приймає завантаження файлів, тимчасово зберігає їх, а потім використовує нашу функцію upload_to_cloudflare для обробки завантаження в R2 та очищення.

6. Найкращі практики та міркування

6.1 Надійна обробка помилок

Хоча наша функція включає базову обробку помилок, у виробничому середовищі вам слід реалізувати більш комплексну обробку помилок та ведення журналу. Розгляньте можливість використання бібліотеки для ведення журналу для відстеження помилок та важливих подій.

6.2 Найкращі практики безпеки

Переконайтеся, що ваші облікові дані R2 зберігаються безпечно і не розкриваються у вашому коді. Використовуйте змінні середовища або безпечну систему управління секретами для захисту конфіденційної інформації.

6.3 Управління розміром файлів

Будьте обізнані про обмеження розміру файлів у вашому додатку та в Cloudflare R2. Для великих файлів розгляньте можливість реалізації багаточастинного завантаження для покращення надійності та продуктивності.

6.4 Оптимізація для одночасних завантажень

Якщо ваш додаток повинен обробляти кілька завантажень одночасно, розгляньте можливість реалізації асинхронних версій функції завантаження або використання потоків для покращення пропускної здатності.

6.5 Тип вмісту та метадані

Розгляньте можливість додавання підтримки для встановлення типу вмісту та користувацьких метаданих для завантажених файлів. Це може бути вирішальним для правильної обробки файлів та організації в межах вашого бакета R2.

7. Висновок

Завантаження файлів до Cloudflare R2 за допомогою Python та бібліотеки boto3 - це простий процес, який можна легко інтегрувати в різні додатки. Створюючи функцію для повторного використання, таку як upload_to_cloudflare, ви можете оптимізувати процеси завантаження файлів у різних частинах вашого додатку.

Оскільки рішення для хмарного зберігання продовжують розвиватися, Cloudflare R2 пропонує привабливий варіант для розробників, які шукають продуктивність, економічність та сумісність з S3. Опановуючи завантаження файлів до R2, ви озброюєте себе цінним навиком у сучасному ландшафті хмарних обчислень.

Пам’ятайте про належну обробку помилок, захист ваших облікових даних та розгляд оптимізації продуктивності при переході до виробничого використання. З цими інструментами та знаннями ви добре підготовлені до використання Cloudflare R2 у ваших Python-додатках.