Blob Functions

SyncGetBlobAsBytesReturnHttpResponse/function.json

@@ -0,0 +1,28 @@
+{
+  "scriptFile": "main.py",
+  "bindings": [
+    {
+      "authLevel": "anonymous",
+      "type": "httpTrigger",
+      "direction": "in",
+      "name": "req",
+      "methods": [
+        "get",
+        "post"
+      ]
+    },
+    {
+      "type": "blob",
+      "direction": "in",
+      "name": "file",
+      "dataType": "binary",
+      "connection": "AzureWebJobsStorage",
+      "path": "python-worker-perf-tests/{infile}"
+    },
+    {
+      "type": "http",
+      "direction": "out",
+      "name": "$return"
+    }
+  ]
+}

SyncGetBlobAsBytesReturnHttpResponse/main.py

@@ -0,0 +1,30 @@
+# Copyright (c) Microsoft Corporation. All rights reserved.
+# Licensed under the MIT License.
+
+import json
+import hashlib
+import azure.functions as azf
+
+
+def main(req: azf.HttpRequest, file: bytes) -> azf.HttpResponse:
+    """
+    Read a blob (bytes) and respond back (in HTTP response) with the number of
+    bytes read and the MD5 digest of the content.
+    """
+    assert isinstance(file, bytes)
+
+    content_size = len(file)
+    content_md5 = hashlib.md5(file).hexdigest()
+
+    response_dict = {
+        'content_size': content_size,
+        'content_md5': content_md5
+    }
+
+    response_body = json.dumps(response_dict, indent=2)
+
+    return azf.HttpResponse(
+        body=response_body,
+        mimetype="application/json",
+        status_code=200
+    )

SyncGetBlobAsBytesStreamReturnHttpResponse/function.json

@@ -0,0 +1,28 @@
+{
+  "scriptFile": "main.py",
+  "bindings": [
+    {
+      "authLevel": "anonymous",
+      "type": "httpTrigger",
+      "direction": "in",
+      "name": "req",
+      "methods": [
+        "get",
+        "post"
+      ]
+    },
+    {
+      "type": "blob",
+      "direction": "in",
+      "name": "file",
+      "dataType": "binary",
+      "connection": "AzureWebJobsStorage",
+      "path": "python-worker-perf-tests/{infile}"
+    },
+    {
+      "type": "http",
+      "direction": "out",
+      "name": "$return"
+    }
+  ]
+}

SyncGetBlobAsBytesStreamReturnHttpResponse/main.py

@@ -0,0 +1,30 @@
+# Copyright (c) Microsoft Corporation. All rights reserved.
+# Licensed under the MIT License.
+
+import json
+import hashlib
+import azure.functions as azf
+
+
+def main(req: azf.HttpRequest, file: azf.InputStream) -> azf.HttpResponse:
+    """
+    Read a blob (as azf.InputStream) and respond back (in HTTP response) with
+    the number of bytes read and the MD5 digest of the content.
+    """
+    file_bytes = file.read()
+
+    content_size = len(file_bytes)
+    content_md5 = hashlib.md5(file_bytes).hexdigest()
+
+    response_dict = {
+        'content_size': content_size,
+        'content_md5': content_md5
+    }
+
+    response_body = json.dumps(response_dict, indent=2)
+
+    return azf.HttpResponse(
+        body=response_body,
+        mimetype="application/json",
+        status_code=200
+    )

SyncGetBlobAsStrReturnHttpResponse/function.json

@@ -0,0 +1,28 @@
+{
+  "scriptFile": "main.py",
+  "bindings": [
+    {
+      "authLevel": "anonymous",
+      "type": "httpTrigger",
+      "direction": "in",
+      "name": "req",
+      "methods": [
+        "get",
+        "post"
+      ]
+    },
+    {
+      "type": "blob",
+      "direction": "in",
+      "name": "file",
+      "dataType": "string",
+      "connection": "AzureWebJobsStorage",
+      "path": "python-worker-perf-tests/{infile}"
+    },
+    {
+      "type": "http",
+      "direction": "out",
+      "name": "$return"
+    }
+  ]
+}

SyncGetBlobAsStrReturnHttpResponse/main.py

@@ -0,0 +1,31 @@
+# Copyright (c) Microsoft Corporation. All rights reserved.
+# Licensed under the MIT License.
+
+import json
+import hashlib
+import azure.functions as azf
+
+
+def main(req: azf.HttpRequest, file: str) -> azf.HttpResponse:
+    """
+    Read a blob (string) and respond back (in HTTP response) with the number of
+    characters read and the MD5 digest of the utf-8 encoded content.
+    """
+    assert isinstance(file, str)
+
+    num_chars = len(file)
+    content_bytes = file.encode('utf-8')
+    content_md5 = hashlib.md5(content_bytes).hexdigest()
+
+    response_dict = {
+        'num_chars': num_chars,
+        'content_md5': content_md5
+    }
+
+    response_body = json.dumps(response_dict, indent=2)
+
+    return azf.HttpResponse(
+        body=response_body,
+        mimetype="application/json",
+        status_code=200
+    )

SyncPutBlobAsBytesReturnHttpResponse/function.json

@@ -0,0 +1,28 @@
+{
+  "scriptFile": "main.py",
+  "bindings": [
+    {
+      "authLevel": "anonymous",
+      "type": "httpTrigger",
+      "direction": "in",
+      "name": "req",
+      "methods": [
+        "get",
+        "post"
+      ]
+    },
+    {
+      "type": "blob",
+      "direction": "out",
+      "name": "file",
+      "dataType": "binary",
+      "connection": "AzureWebJobsStorage",
+      "path": "python-worker-perf-tests/{outfile}"
+    },
+    {
+      "type": "http",
+      "direction": "out",
+      "name": "$return"
+    }
+  ]
+}

SyncPutBlobAsBytesReturnHttpResponse/main.py

@@ -0,0 +1,41 @@
+# Copyright (c) Microsoft Corporation. All rights reserved.
+# Licensed under the MIT License.
+
+import random
+import json
+import hashlib
+import azure.functions as azf
+
+
+def main(req: azf.HttpRequest, file: azf.Out[bytes]) -> azf.HttpResponse:
+    """
+    Write a blob (bytes) and respond back (in HTTP response) with the number of
+    bytes written and the MD5 digest of the content.
+    The number of bytes to write are specified in the input HTTP request.
+    """
+    content_size = int(req.params['content_size'])
+
+    # When this is set, then 0x01 byte is repeated content_size number of
+    # times to use as input.
+    # This is to avoid generating random input for large size which can be
+    # slow.
+    if 'no_random_input' in req.params:
+        content = b'\x01' * content_size
+    else:
+        content = bytearray(random.getrandbits(8) for _ in range(content_size))
+    content_md5 = hashlib.md5(content).hexdigest()
+
+    file.set(content)
+
+    response_dict = {
+        'content_size': content_size,
+        'content_md5': content_md5
+    }
+
+    response_body = json.dumps(response_dict, indent=2)
+
+    return azf.HttpResponse(
+        body=response_body,
+        mimetype="application/json",
+        status_code=200
+    )

SyncPutBlobAsStrReturnHttpResponse/function.json

@@ -0,0 +1,28 @@
+{
+  "scriptFile": "main.py",
+  "bindings": [
+    {
+      "authLevel": "anonymous",
+      "type": "httpTrigger",
+      "direction": "in",
+      "name": "req",
+      "methods": [
+        "get",
+        "post"
+      ]
+    },
+    {
+      "type": "blob",
+      "direction": "out",
+      "name": "file",
+      "dataType": "string",
+      "connection": "AzureWebJobsStorage",
+      "path": "python-worker-perf-tests/{outfile}"
+    },
+    {
+      "type": "http",
+      "direction": "out",
+      "name": "$return"
+    }
+  ]
+}

SyncPutBlobAsStrReturnHttpResponse/main.py

@@ -0,0 +1,39 @@
+# Copyright (c) Microsoft Corporation. All rights reserved.
+# Licensed under the MIT License.
+
+import string
+import random
+import json
+import hashlib
+import azure.functions as azf
+
+
+def main(req: azf.HttpRequest, file: azf.Out[str]) -> azf.HttpResponse:
+    """
+    Write a blob (string) and respond back (in HTTP response) with the number of
+    characters written and the MD5 digest of the utf-8 encoded content.
+    The number of characters to write are specified in the input HTTP request.
+    """
+    num_chars = int(req.params['num_chars'])
+
+    content = ''.join(random.choices(string.ascii_uppercase + string.digits,
+                                     k=num_chars))
+    content_bytes = content.encode('utf-8')
+    content_size = len(content_bytes)
+    content_md5 = hashlib.md5(content_bytes).hexdigest()
+
+    file.set(content)
+
+    response_dict = {
+        'num_chars': num_chars,
+        'content_size': content_size,
+        'content_md5': content_md5
+    }
+
+    response_body = json.dumps(response_dict, indent=2)
+
+    return azf.HttpResponse(
+        body=response_body,
+        mimetype="application/json",
+        status_code=200
+    )

SyncPutGetMultipleBlobsAsBytesReturnHttpResponse/function.json

@@ -0,0 +1,52 @@
+{
+  "scriptFile": "main.py",
+  "bindings": [
+    {
+      "authLevel": "anonymous",
+      "type": "httpTrigger",
+      "direction": "in",
+      "name": "req",
+      "methods": [
+        "get",
+        "post"
+      ]
+    },
+    {
+      "type": "blob",
+      "direction": "in",
+      "name": "inputfile1",
+      "dataType": "binary",
+      "connection": "AzureWebJobsStorage",
+      "path": "python-worker-perf-tests/{infile1}"
+    },
+    {
+      "type": "blob",
+      "direction": "in",
+      "name": "inputfile2",
+      "dataType": "binary",
+      "connection": "AzureWebJobsStorage",
+      "path": "python-worker-perf-tests/{infile2}"
+    },
+    {
+      "type": "blob",
+      "direction": "out",
+      "name": "outputfile1",
+      "dataType": "binary",
+      "connection": "AzureWebJobsStorage",
+      "path": "python-worker-perf-tests/{outfile1}"
+    },
+    {
+      "type": "blob",
+      "direction": "out",
+      "name": "outputfile2",
+      "dataType": "binary",
+      "connection": "AzureWebJobsStorage",
+      "path": "python-worker-perf-tests/{outfile2}"
+    },
+    {
+      "type": "http",
+      "direction": "out",
+      "name": "$return"
+    }
+  ]
+}