Azure Function: HTTPTrigger Function with Snowflake Connector

__init__.py

import logging

import azure.functions as func

import snowflake.connector


def get_connection():
    return snowflake.connector.connect(
        user='<your_user>',
        password='<your_password>',
        account='<your_account>',
        warehouse='<your_virtual_warehouse>'
    )


def main(req: func.HttpRequest) -> func.HttpResponse:
    logging.info('Python HTTP trigger function processed a request.')

    ctx = get_connection()
    result_string = ""

    schema = req.params.get('schema')
    table = req.params.get('table')

    if schema and table and ctx :
        cursor = ctx.cursor()

        try:
            results = cursor.execute("SELECT * FROM SNOWFLAKE_SAMPLE_DATA.{}.{}".format(schema, table))
            for row in results:
                result_string = result_string + str(row[0]) + " " + str(row[1]) + "\n"
            result_string += "\n\nQuery ID: " + cursor.sfqid
        except Exception as e:
            print(e)
        finally:
            cursor.close()
        ctx.close()

        return func.HttpResponse(result_string)
    else:
        return func.HttpResponse(
             "Request failed.",
             status_code=400
        )