1. Wprowadzenie

W stale ewoluującym krajobrazie rozwiązań do przechowywania w chmurze, Cloudflare R2 wyłonił się jako potężny konkurent, oferując API kompatybilne z S3, konkurencyjne ceny i imponującą wydajność. Ten artykuł przeprowadzi Cię przez proces przesyłania plików do Cloudflare R2 za pomocą Pythona, skupiając się na tworzeniu wszechstronnej, wielokrotnego użytku funkcji, którą można bezproblemowo zintegrować z różnymi aplikacjami.

2. Konfiguracja środowiska

2.1 Wymagania wstępne

Zanim zagłębisz się w implementację, upewnij się, że masz następujące elementy:

• Python 3.7 lub nowszy zainstalowany w systemie
• Konto Cloudflare z włączonym R2
• Dostęp do poświadczeń swojego bucketa R2 (ID konta, ID klucza dostępu i tajny klucz dostępu)

2.2 Instalacja wymaganych pakietów

Będziemy korzystać z biblioteki boto3 do interakcji z Cloudflare R2. Zainstaluj ją za pomocą pip:

1

pip install boto3

3. Konfiguracja klienta S3 dla Cloudflare R2

Aby wchodzić w interakcję z Cloudflare R2, musimy skonfigurować klienta S3 z odpowiednimi ustawieniami:

 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 Zrozumienie konfiguracji

• endpoint_url: To jest punkt wejścia dla Twojego bucketa Cloudflare R2. Zastąp <accountid> swoim rzeczywistym ID konta Cloudflare.
• aws_access_key_id i aws_secret_access_key: To są poświadczenia Twojego bucketa R2. Zastąp je swoimi rzeczywistymi wartościami.
• config=Config(signature_version="s3v4"): To określa użycie Signature Version 4, które jest wymagane przez Cloudflare R2 do uwierzytelniania.

4. Tworzenie funkcji wielokrotnego użytku do przesyłania

Stwórzmy wszechstronną funkcję, która obsługuje przesyłanie plików do 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 = "<nazwa_twojego_bucketa>"
CLOUDFLARE_PUBLIC_URL = "https://<twoja_niestandardowa_domena>/"

def przeslij_do_cloudflare(sciezka_pliku: str, nazwa_obiektu: Optional[str] = None) -> str:
    """
    Prześlij plik do Cloudflare R2, zwróć publiczny URL i usuń lokalny plik.

    :param sciezka_pliku: Ścieżka do pliku do przesłania
    :param nazwa_obiektu: Nazwa obiektu S3. Jeśli nie określono, używana jest nazwa bazowa sciezka_pliku
    :return: Publiczny URL przesłanego pliku
    """
    # Jeśli nazwa_obiektu S3 nie została określona, użyj nazwy bazowej sciezka_pliku
    if nazwa_obiektu is None:
        nazwa_obiektu = os.path.basename(sciezka_pliku)

    try:
        # Prześlij plik
        s3.upload_file(sciezka_pliku, BUCKET_NAME, nazwa_obiektu)
        
        # Wygeneruj publiczny URL dla przesłanego pliku
        url = f"{CLOUDFLARE_PUBLIC_URL}{nazwa_obiektu}"
        
        # Usuń lokalny plik
        os.remove(sciezka_pliku)
        
        return url
    except Exception as e:
        print(f"Wystąpił błąd: {e}")
        return ""

4.1 Rozbicie funkcji

• Funkcja przyjmuje dwa parametry: sciezka_pliku (wymagany) i nazwa_obiektu (opcjonalny).
• Jeśli nazwa_obiektu nie jest podana, domyślnie używana jest nazwa bazowa ścieżki pliku.
• Przesyła plik do określonego bucketa R2 za pomocą s3.upload_file().
• Po udanym przesłaniu generuje publiczny URL dla pliku.
• Następnie lokalny plik jest usuwany, aby zwolnić miejsce.
• Jeśli wystąpi jakikolwiek błąd podczas procesu, jest on przechwytywany, wydrukowany i zwracany jest pusty ciąg znaków.

5. Integracja z FastAPI

Oto przykład, jak zintegrować funkcję przeslij_do_cloudflare z aplikacją 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("/przeslij")
async def przeslij_plik(plik: UploadFile = File(...)):
    # Zapisz przesłany plik tymczasowo
    temp_sciezka_pliku = f"/tmp/{plik.filename}"
    with open(temp_sciezka_pliku, "wb") as bufor:
        bufor.write(await plik.read())
    
    # Prześlij do Cloudflare R2
    url = przeslij_do_cloudflare(temp_sciezka_pliku)
    
    if url:
        return JSONResponse(content={"url_pliku": url}, status_code=200)
    else:
        return JSONResponse(content={"blad": "Nie udało się przesłać pliku"}, status_code=500)

Ten endpoint akceptuje przesyłane pliki, zapisuje je tymczasowo, a następnie używa naszej funkcji przeslij_do_cloudflare do obsługi przesyłania do R2 i czyszczenia.

6. Najlepsze praktyki i uwagi

6.1 Solidna obsługa błędów

Chociaż nasza funkcja zawiera podstawową obsługę błędów, w środowisku produkcyjnym powinieneś zaimplementować bardziej kompleksową obsługę błędów i logowanie. Rozważ użycie biblioteki logowania do śledzenia błędów i ważnych zdarzeń.

6.2 Najlepsze praktyki bezpieczeństwa

Upewnij się, że Twoje poświadczenia R2 są przechowywane bezpiecznie i nie są ujawniane w kodzie. Używaj zmiennych środowiskowych lub bezpiecznego systemu zarządzania sekretami do ochrony wrażliwych informacji.

6.3 Zarządzanie rozmiarem plików

Bądź świadomy limitów rozmiaru plików w swojej aplikacji i w Cloudflare R2. W przypadku dużych plików rozważ zaimplementowanie przesyłania wieloczęściowego, aby poprawić niezawodność i wydajność.

6.4 Optymalizacja dla równoczesnych przesyłań

Jeśli Twoja aplikacja musi obsługiwać wiele przesyłań jednocześnie, rozważ zaimplementowanie asynchronicznych wersji funkcji przesyłania lub użycie wątków w celu poprawy przepustowości.

6.5 Typ zawartości i metadane

Rozważ dodanie wsparcia dla ustawiania typu zawartości i niestandardowych metadanych dla przesyłanych plików. Może to być kluczowe dla prawidłowej obsługi plików i organizacji w Twoim buckecie R2.

7. Podsumowanie

Przesyłanie plików do Cloudflare R2 za pomocą Pythona i biblioteki boto3 jest prostym procesem, który można łatwo zintegrować z różnymi aplikacjami. Tworząc funkcję wielokrotnego użytku, taką jak przeslij_do_cloudflare, możesz usprawnić procesy przesyłania plików w różnych częściach swojej aplikacji.

Ponieważ rozwiązania do przechowywania w chmurze stale ewoluują, Cloudflare R2 oferuje atrakcyjną opcję dla programistów poszukujących wydajności, opłacalności i kompatybilności z S3. Opanowując przesyłanie plików do R2, wyposażasz się w cenną umiejętność w nowoczesnym krajobrazie chmury obliczeniowej.

Pamiętaj, aby elegancko obsługiwać błędy, zabezpieczać swoje poświadczenia i rozważyć optymalizacje wydajności, przechodząc do użycia produkcyjnego. Z tymi narzędziami i wiedzą jesteś dobrze przygotowany do wykorzystania Cloudflare R2 w swoich aplikacjach Pythona.