Skip to content

Blobs (/blobs/)

In general you interact with blobs as attributes of other objects -- blobs being the most obvious example. However, there is limited support in the REST API for interacting directly with blobs as well. Blobs are also considered a special case in that they are not namespaced like most other objects. That is, possession of the UUID of a blob is considered evidence that you should have access to it. This is because blobs can be shared between objects if the data for those objects is currently the identical. This is also why only administrators can list all blobs in a given Shaken Fist cluster.

Note

For a detailed reference on the state machine for blobs, see the developer documentation on object states.

Fetching information about a blob

If you know the UUID of a blob, then you can GET information about that blob from the REST API, as well as fetching the actual data the blob is storing as well.

REST API calls
Python API client: get a specific blob 
import json
from shakenfist_client import apiclient

sf_client = apiclient.Client()
b = sf_client.get_blob('578da8b6-eb98-4e10-bb36-e4d4d763d312')
print(json.dumps(b, indent=4, sort_keys=True))
Python API client: download the data for a specific blob

This example requires retry logic to handle the HTTP connection dropping while transferring large files.

import http
from shakenfist_client import apiclient
import requests
import sys
import urllib3

sf_client = apiclient.Client()

total = 0
connection_failures = 0
done = False

with open('output', 'wb') as f:
    while not done:
        bytes_in_attempt = 0

        try:
            for chunk in sf_client.get_blob_data(
                    '578da8b6-eb98-4e10-bb36-e4d4d763d312', offset=total):
                received = len(chunk)
                f.write(chunk)
                bytes_in_attempt += received
                total += received

            done = True

        except urllib3.exceptions.NewConnectionError as e:
            connection_failures += 1
            if connection_failures > 2:
                print('HTTP connection repeatedly failed: %s' % e)
                sys.exit(1)

        except (ConnectionResetError, http.client.IncompleteRead,
                urllib3.exceptions.ProtocolError,
                requests.exceptions.ChunkedEncodingError) as e:
            # An API error (or timeout) occurred. Retry unless we got nothing.
            if bytes_in_attempt == 0:
                print('HTTP connection dropped without transferring data: %s' % e)
                sys.exit(1)
Python API client: search for a blob by sha512 hash

Note that this call is not supported by older versions of the Shaken Fist REST API.

import hashlib
import json
from shakenfist_client import apiclient

sf_client = apiclient.Client()
if not sf_client.check_capability('blob-search-by-hash'):
    print('Searching by hash is not supported')
else:
    sha512_hash = hashlib.sha512()
    with open('input', 'rb') as f:
        d = f.read(4096)
        while d:
            sha512_hash.update(d)
            d = f.read(4096)

    print('Searching for a pre-existing blob with this hash...')
    b = sf_client.get_blob_by_sha512(sha512_hash.hexdigest())
    if not b:
        print('No matching blob found')
    else:
        print('Blob %s is a match' % b['uuid'])

Metadata

All objects exposed by the REST API may have metadata associated with them. This metadata is for storing values that are of interest to the owner of the resources, not Shaken Fist. Shaken Fist does not attempt to interpret these values at all, with the exception of the instance affinity metadata values. The metadata store is in the form of a key value store, and a general introduction is available in the user guide.

REST API calls
Python API client: set metadata on a blob 
from shakenfist_client import apiclient

sf_client = apiclient.Client()
sf_client.set_blob_metadata_item(blob_uuid, 'foo', 'bar')
Python API client: get metadata for a blob 
import json
from shakenfist_client import apiclient

sf_client = apiclient.Client()
md = sf_client.get_blob_metadata(blob_uuid)
print(json.dumps(md, indent=4, sort_keys=True))
Python API client: delete metadata for a blob 
import json
from shakenfist_client import apiclient

sf_client = apiclient.Client()
sf_client.delete_blob_metadata_item(blob_uuid, 'foo')