Uploading txt to blob storage test

OD1995 · OD1995 · commit 85eae22dfc89 · 2020-09-29T10:39:04.000+01:00
diff --git a/HttpTrigger7/__init__.py b/HttpTrigger7/__init__.py
@@ -0,0 +1,34 @@
+import logging
+import pyodbc
+import pandas as pd
+import azure.functions as func
+
+
+def main(req: func.HttpRequest) -> func.HttpResponse:
+    logging.info("getAzureBlobVideos started")
+    ## Get information used to create connection string
+    username = 'matt.shepherd'
+    # password = os.getenv("sqlPassword")
+    password = "4rsenal!PG01"
+    driver = '{ODBC Driver 17 for SQL Server}'
+    # server = os.getenv("sqlServer")
+    server = "fse-inf-live-uk.database.windows.net"
+    database = 'AzureCognitive'
+    table = 'AzureBlobVideos'
+    ## Create connection string
+    connectionString = f'DRIVER={driver};SERVER={server};PORT=1433;DATABASE={database};UID={username};PWD={password}'
+    logging.info(f'Connection string created: {connectionString}')
+    ## Create SQL query to use
+    sqlQuery = f"SELECT * FROM {table}"
+    with pyodbc.connect(connectionString) as conn:
+        ## Get SQL table in pandas DataFrame
+        df = pd.read_sql(sql=sqlQuery,
+                            con=conn)
+    logging.info(f"Dataframe with shape {df.shape} received")
+    ## Dict - VideoName : (Sport,Event) 
+    dfDict = {vn : (s,e)
+                for vn,s,e in zip(df.VideoName,
+                                    df.Sport,
+                                    df.Event)}
+
+    return func.HttpResponse(str(dfDict))
diff --git a/HttpTrigger7/function.json b/HttpTrigger7/function.json
@@ -0,0 +1,20 @@
+{
+  "scriptFile": "__init__.py",
+  "bindings": [
+    {
+      "authLevel": "anonymous",
+      "type": "httpTrigger",
+      "direction": "in",
+      "name": "req",
+      "methods": [
+        "get",
+        "post"
+      ]
+    },
+    {
+      "type": "http",
+      "direction": "out",
+      "name": "$return"
+    }
+  ]
+}
diff --git a/HttpTrigger7/sample.dat b/HttpTrigger7/sample.dat
@@ -0,0 +1,3 @@
+{
+    "name": "Azure"
+}
diff --git a/HttpTrigger8/__init__.py b/HttpTrigger8/__init__.py
@@ -0,0 +1,20 @@
+import logging
+from azure.storage.blob import BlockBlobService
+
+import azure.functions as func
+
+
+def main(req: func.HttpRequest) -> func.HttpResponse:
+    ## Create BlockBlobService
+    connectionStringOutput = "DefaultEndpointsProtocol=https;AccountName=fsevideos;AccountKey=xfYncTDRCowSrISbdsSknM05jqOrJXc4Oavq7BQ56yR7uQ7MCeL5aXmBsbsE+SZ+++xGt2oy6FvrEdpryc+vwQ==;EndpointSuffix=core.windows.net"
+    block_blob_service = BlockBlobService(connection_string=connectionStringOutput)
+    logging.info(f'BlockBlobService created for account "{block_blob_service.account_name}"')
+    ## Create some text to upload to the blob storage account
+    s = "some test letters"
+    logging.info(f"About to create txt file containing '{s}'")
+    ## Create blob
+    block_blob_service.create_blob_from_text(container_name="us-office",
+                                                blob_name=s,
+                                                text="test.txt")
+    logging.info("Blob created")
+    return func.HttpResponse(str(s))
diff --git a/HttpTrigger8/function.json b/HttpTrigger8/function.json
@@ -0,0 +1,20 @@
+{
+  "scriptFile": "__init__.py",
+  "bindings": [
+    {
+      "authLevel": "anonymous",
+      "type": "httpTrigger",
+      "direction": "in",
+      "name": "req",
+      "methods": [
+        "get",
+        "post"
+      ]
+    },
+    {
+      "type": "http",
+      "direction": "out",
+      "name": "$return"
+    }
+  ]
+}
diff --git a/HttpTrigger8/sample.dat b/HttpTrigger8/sample.dat
@@ -0,0 +1,3 @@
+{
+    "name": "Azure"
+}
