Bloques AWS S3 - VisioForge Media Blocks SDK .Net¶

Media Blocks SDK .Net

Los bloques AWS S3 permiten la interacción con Amazon Simple Storage Service (S3) para leer archivos de medios como fuentes o escribir archivos de medios como sinks dentro de sus pipelines.

AWSS3SinkBlock¶

El AWSS3SinkBlock le permite escribir datos de medios de su pipeline a un archivo en un bucket de AWS S3. Esto es útil para almacenar medios grabados, archivos transcodificados u otras salidas directamente al almacenamiento en la nube.

Información del bloque¶

Nombre: AWSS3SinkBlock.

Configuraciones¶

El AWSS3SinkBlock se configura usando AWSS3SinkSettings. Propiedades principales:

• Uri (string): La URI del objeto S3 (ej., "s3://nombre-de-su-bucket/ruta/a/archivo/salida.mp4"). Alternativamente, defina Bucket y Key por separado.
• Bucket (string): El nombre del bucket S3 de destino.
• Key (string): La clave del objeto (ruta dentro del bucket).
• AccessKey (string): Su clave de acceso de AWS.
• SecretAccessKey (string): Su clave de acceso secreta de AWS.
• Region (string): La región de AWS donde está ubicado el bucket (por defecto "us-west-1").
• SessionToken (string, opcional): Token de sesión temporal de AWS STS, si usa credenciales temporales.
• EndpointUri (string, opcional): URI de endpoint personalizado compatible con S3.
• ContentType (string, opcional): El tipo MIME del contenido que se está cargando (ej., "video/mp4").
• ContentDisposition (string, opcional): Encabezado Content-Disposition para el objeto cargado.
• Metadata (Dictionary<string, string>, opcional): Un mapa de metadatos de usuario a almacenar con el objeto.
• ForcePathStyle (bool, opcional): Forzar al cliente a usar direccionamiento de estilo ruta para buckets.
• UseMultipartUpload (bool, opcional, por defecto true): Usar carga multipart para archivos grandes.
• PartSize (ulong, opcional, por defecto 5 MB): Tamaño en bytes de una parte individual usada para la carga multipart.
• OnError (S3SinkOnError, opcional): Cómo manejar los errores durante la carga.
• RequestTimeout (TimeSpan, opcional, por defecto 15s): Tiempo de espera para solicitudes S3 (establezca TimeSpan.Zero para infinito).
• RetryAttempts (uint, opcional, por defecto 5): Número de reintentos antes de abandonar una solicitud.

Pipeline de ejemplo¶

graph LR;
    SystemVideoSourceBlock-->VideoEncoderBlock;
    VideoEncoderBlock-->MP4SinkBlock;
    SystemAudioSourceBlock-->AudioEncoderBlock;
    AudioEncoderBlock-->MP4SinkBlock;
    MP4SinkBlock-->AWSS3SinkBlock;

Código de ejemplo¶

var pipeline = new MediaBlocksPipeline();

// Crear fuente de video (ej., webcam)
var videoDevice = (await DeviceEnumerator.Shared.VideoSourcesAsync())[0];
var videoSourceSettings = new VideoCaptureDeviceSourceSettings(videoDevice);
var videoSource = new SystemVideoSourceBlock(videoSourceSettings);

// Crear fuente de audio (ej., micrófono)
var audioDevice = (await DeviceEnumerator.Shared.AudioSourcesAsync())[0];
var audioSourceSettings = audioDevice.CreateSourceSettings(audioDevice.Formats[0].ToFormat());
var audioSource = new SystemAudioSourceBlock(audioSourceSettings);

// Crear codificador de video
var h264Settings = new OpenH264EncoderSettings(); // Configuraciones de ejemplo del codificador
var videoEncoder = new H264EncoderBlock(h264Settings);

// Crear codificador de audio
var opusSettings = new OPUSEncoderSettings(); // Configuraciones de ejemplo del codificador
var audioEncoder = new OPUSEncoderBlock(opusSettings);

// Crear un muxer MP4 en modo mux-only — produce un pad de salida muxed en lugar de escribir un archivo.
var mp4MuxSettings = new MP4SinkSettings(string.Empty) { MuxOnly = true };
var mp4Muxer = new MP4SinkBlock(mp4MuxSettings);

// Configurar AWSS3SinkSettings
var s3SinkSettings = new AWSS3SinkSettings
{
    Uri = "s3://nombre-de-su-bucket/salida/video-grabado.mp4",
    AccessKey = "SU_CLAVE_DE_ACCESO_AWS",
    SecretAccessKey = "SU_CLAVE_DE_ACCESO_SECRETA_AWS",
    Region = "su-region-aws", // ej., "us-east-1"
    ContentType = "video/mp4"
};

var s3Sink = new AWSS3SinkBlock(s3SinkSettings);

// Conectar ruta de video
pipeline.Connect(videoSource.Output, videoEncoder.Input);
pipeline.Connect(videoEncoder.Output, mp4Muxer.CreateNewInput(MediaBlockPadMediaType.Video));

// Conectar ruta de audio
pipeline.Connect(audioSource.Output, audioEncoder.Input);
pipeline.Connect(audioEncoder.Output, mp4Muxer.CreateNewInput(MediaBlockPadMediaType.Audio));

// Conectar muxer al sink S3
pipeline.Connect(mp4Muxer.Output, s3Sink.Input);

// Verificar si AWSS3Sink está disponible
if (!AWSS3SinkBlock.IsAvailable())
{
    Console.WriteLine("El Bloque AWS S3 Sink no está disponible. Verifique los redistribuibles del SDK.");
    return;
}

// Iniciar pipeline
await pipeline.StartAsync();

// ... esperar a que termine la grabación ...

// Detener pipeline
await pipeline.StopAsync();

Observaciones¶

Puede verificar si el AWSS3SinkBlock está disponible en tiempo de ejecución usando el método estático AWSS3SinkBlock.IsAvailable(). Esto asegura que los plugins GStreamer subyacentes necesarios y los componentes del SDK de AWS estén presentes.

Plataformas¶

Windows, macOS, Linux. (La disponibilidad depende del plugin AWS de GStreamer y el soporte del SDK de AWS en estas plataformas).