Upload a Software Image

import base64
import hashlib
import json
import requests
URL = 'https://<host>/api/v1/devicesoftware/'
USER = '<user>'
PASSWORD = '<password>'
ORG_ID = 'ff118da5-000a-483c-91a1-45d478478548'
MIN_SIZE = 5 * 1024 * 1024
FILENAME = '<image_filename>'
DIRECTORY = '<path>'
def file_sha(contents):
    h = hashlib.sha256()
    data = contents.read(MIN_SIZE)
    while data:
        h.update(data)
        data = contents.read(MIN_SIZE)
    return h.hexdigest()
def print_sw_images():
    response = requests.get(URL + ORG_ID + '/images', auth=(USER, PASSWORD), verify=False)
    images = decode(response)
    print('There are %d images' % len(images))
    for img in images:
        print(img.get('name'))
def decode(response):
    if response.status_code != 200:
        print(response.status_code)
        print(response.text)
        exit(1)
    return json.loads(response.text)
def upload(file_name: str, data, file_sha256: str, vendor: str, series: str, release: str, version: str):
    headers = {'Content-Type': 'application/json'}
    url = URL + ORG_ID + '/upload'
    response = requests.post(url, auth=(USER, PASSWORD), headers=headers, verify=False, json={
        'name': file_name,
        'expected_sha256': file_sha256,
        'device_vendor': vendor,
        'device_series_list': [series],
        'release': release,
        'version': version,
    })
    r = decode(response)
    upload_id = r.get('id')
    print('Uploading %s' % upload_id)
    url = url + '/' + upload_id
    file_slice = read_min(data)
    while file_slice:
        encoded = base64.b64encode(file_slice).decode('utf-8')
        response = requests.put(url, auth=(USER, PASSWORD), headers=headers, verify=False, json={
            'file_data': 'data:application/octet-stream;base64,' + encoded
        })
        msg = decode(response)
        print(msg)
        file_slice = read_min(data)
    response = requests.put(url, auth=(USER, PASSWORD), headers=headers, verify=False, json={
        "complete": True
    })
    msg = decode(response)
    print(msg)
def read_min(file):
    ret = b''
    while len(ret) < MIN_SIZE:
        file_slice = file.read(MIN_SIZE)
        ret = ret + file_slice
        if not file_slice:
            break
    return ret
if __name__ == '__main__':
    print_sw_images()
    with open(DIRECTORY + FILENAME, 'rb') as iso:
        sha = file_sha(iso)
        print(sha)
    with open(DIRECTORY + FILENAME, 'rb') as iso:
        upload(FILENAME, iso, sha, 'Juniper', 'ACX7100', '22.2R1.12-EVO', '22.2')
    print_sw_images()

root@controller-65:~# kubectl exec -ti -n rook-ceph $(kubectl get po -n rook-ceph -l app=rook-ceph-tools -o jsonpath={..metadata.name}) -- ceph osd pool get-quota object-store.rgw.buckets.data
quotas for pool 'object-store.rgw.buckets.data':
  max objects: N/A
  max bytes : 20 GiB  (current num bytes: 15459654543 bytes)