klingai-storage-integration

# Kling AI Storage Integration ## Overview Kling AI video URLs from `task_result.videos[].url` are temporary CDN links that expire. You must download and store videos in your own storage. This skill covers S3, GCS, and Azure Blob. ## Download from Kling CDN ```python import requests import os def download_video(video_url: str, output_dir: str = "output") -> str: """Download generated video from Kling CDN.""" os.makedirs(output_dir, exist_ok=True) # Extract filename or generate one filename = video_url.split("/")[-1].split("?")[0] if not filename.endswith(".mp4"): filename = f"kling_{int(time.time())}.mp4" filepath = os.path.join(output_dir, filename) response = requests.get(video_url, stream=True, timeout=120) response.raise_for_status() with open(filepath, "wb") as f: for chunk in response.iter_content(chunk_size=8192): f.write(chunk) size_mb = os.path.getsize(filepath) / (1024 * 1024) print(f"Downloaded: {filepath} ({size_mb:.1f} MB)") return filepath ``` ## Upload to AWS S3 ```python import boto3 def upload_to_s3(filepath: str, bucket: str, key_prefix: str = "kling-videos/") -> str: """Upload video to S3 and return public URL.""" s3 = boto3.client("s3") filename = os.path.basename(filepath) s3_key = f"{key_prefix}{filename}" s3.upload_file( filepath, bucket, s3_key, ExtraArgs={"ContentType": "video/mp4", "CacheControl": "max-age=86400"} ) ur...