Metadata Tagging

1
import requests
2
import json
3
import os
4
import time
5
6
def send_reka_tag_request(video_path: str, api_key: str):
7
    if not video_path:
8
        raise ValueError("video path is required")
9
    headers = {
10
        "X-API-Key": api_key,
11
    }
12
    endpoint_url = f"{BASE_URL}/v1/qa/quicktag"
13
    print(f"{endpoint_url=}")
14
    print(f"{headers=}")
15
16
    start_time = time.time()
17
    with open(video_path, 'rb') as f:
18
        try:
19
            # The dictionary key 'file' matches the FastAPI parameter name
20
            files = {'video': (os.path.basename(video_path), f, 'video/mp4')}
21
            print(f"{files=}")
22
23
            # Send the POST request
24
            response = requests.post(endpoint_url, files=files, headers=headers, timeout=120)
25
            duration = time.time() - start_time
26
            print(f"Request took {duration:.2f} seconds")
27
            try:
28
                response.raise_for_status()
29
            except requests.HTTPError as e:
30
                try:
31
                    err_json = response.json()
32
                    print("Error JSON:\n", json.dumps(err_json, indent=4))
33
                except ValueError:
34
                    print("Error Text:", response.text)
35
                raise e
36
            return response
37
38
        except requests.exceptions.RequestException as e:
39
            print(f"An error occurred during the quick tag request: {e}")
40
            return None

1
import requests
2
import json
3
import time
4
5
def send_indexed_tag_request(video_id: str, api_key: str):
6
    if not video_id:
7
        raise ValueError("video_id is required")
8
9
    # Form payload (NOT JSON)
10
    form_data = {
11
        "video_id": video_id,
12
    }
13
    headers = {
14
        "X-API-Key": api_key,
15
    }
16
    endpoint_url = f"{BASE_URL}/v1/qa/indexedtag"
17
    print(f"{endpoint_url=}")
18
    print(f"{headers=}")
19
    print(f"{form_data=}")
20
21
    start_time = time.time()
22
    try:
23
        # No stream=True; endpoint returns the final string
24
        response = requests.post(endpoint_url, data=form_data, headers=headers, timeout=120)
25
        duration = time.time() - start_time
26
        print(f"Request took {duration:.2f} seconds")
27
        try:
28
            response.raise_for_status()
29
        except requests.HTTPError as e:
30
            # Try to show any error payload
31
            try:
32
                err_json = response.json()
33
                print("Error JSON:\n", json.dumps(err_json, indent=4))
34
            except ValueError:
35
                print("Error Text:", response.text)
36
            raise e
37
        return response
38
39
    except requests.exceptions.RequestException as e:
40
        print(f"An error occurred during the indexed tag request: {e}")
41
        return None