Computación de Funciones e Integración con OSS

Home PDF

Este código demuestra cómo integrar Alibaba Cloud Function Compute con OSS (Object Storage Service). Descarga un archivo de una URL especificada y lo sube a un bucket de OSS.

Código

# -*- coding: utf-8 -*-
import oss2
import requests
import logging
import os

def handler(event, context):
    # Configuración
    # model_url = "https://huggingface.co/TheBloke/Mistral-7B-Instruct-v0.2-GGUF/resolve/main/mistral-7b-instruct-v0.2.Q4_K_M.gguf"

    model_url = "https://storage.googleapis.com/lzwjava1/ss_urls.txt"
    oss_bucket_name = "lzw-download"  # Nombre de tu bucket
    oss_endpoint = "oss-cn-hangzhou.aliyuncs.com"  # Endpoint público
    
    try:
        # Usa el ARN del rol proporcionado para crear el objeto de autenticación
        role_arn = "acs:ram::1768386076294612:role/fc"
        auth = oss2.Auth(
            os.environ['ALIBABA_CLOUD_ACCESS_KEY_ID'],
            os.environ['ALIBABA_CLOUD_ACCESS_KEY_SECRET']
        )
        
        sts_auth = oss2.StsAuth(
            os.environ['ALIBABA_CLOUD_ACCESS_KEY_ID'],
            os.environ['ALIBABA_CLOUD_ACCESS_KEY_SECRET'],
            os.environ['ALIBABA_CLOUD_SECURITY_TOKEN']
        )

        # 2. Inicializa el cliente OSS con el endpoint correcto
        bucket = oss2.Bucket(
            sts_auth,
            oss_endpoint,
            oss_bucket_name
        )

        # 3. Descarga y subida en streaming
        logging.info("Comenzando la descarga...")
        with requests.get(model_url, stream=True) as response:
            response.raise_for_status()
            
            # Subir a OSS
            result = bucket.put_object(
                'models/mistral-7b-instruct-v0.2.Q4_K_M.gguf',
                response.iter_content(chunk_size=1024*1024)
            )
            
        if result.status == 200:
            logging.info("Subida exitosa!")
            return "Success"
        else:
            raise Exception(f"Error en la subida a OSS: {result.status}")

    except Exception as e:
        logging.error(f"Error: {str(e)}")
        raise e

Error

Encontramos el mismo error que antes. Parece que se requiere una VPN para completar esta tarea.

2025-01-24 17:43:342025-01-24 17:43:34 1-679360a6-154b432a-15cadcce0c27 [ERROR] { “errorMessage”: “HTTPSConnectionPool(host=’huggingface.co’, port=443): Max retries exceeded with url: /TheBloke/Mistral-7B-Instruct-v0.2-GGUF/resolve/main/mistral-7b-instruct-v0.2.Q4_K_M.gguf (Caused by NewConnectionError(‘<urllib3.connection.HTTPSConnection object at 0x7f7d3c289f60>: Failed to establish a new connection: [Errno 101] Network is unreachable’))”


Back 2025.02.22 Donate