def METHOD_NAME():
    try:
        CONNECTION_STRING = os.environ['AZURE_STORAGE_CONNECTION_STRING']
    except KeyError:
        print("AZURE_STORAGE_CONNECTION_STRING must be set.")
        sys.exit(1)
    datalake_service_client = DataLakeServiceClient.from_connection_string(CONNECTION_STRING)
    filesystem_name = "quickqueryfilesystem"
    filesystem_client = datalake_service_client.get_file_system_client(filesystem_name)
    try:
        filesystem_client.create_file_system()
    except:
        pass
    # [START query]
    errors = []
    def on_error(error):
        errors.append(error)
    # upload the csv file
    file_client = datalake_service_client.get_file_client(filesystem_name, "csvfile")
    file_client.upload_data(CSV_DATA, overwrite=True)
    # select the second column of the csv file
    query_expression = "SELECT _2 from DataLakeStorage"
    input_format = DelimitedTextDialect(delimiter=',', quotechar='"', lineterminator='\n', escapechar="", has_header=False)
    output_format = DelimitedJsonDialect(delimiter='\n')
    reader = file_client.query_file(query_expression, on_error=on_error, file_format=input_format, output_format=output_format)
    content = reader.readall()
    # [END query]
    print(content)
    filesystem_client.delete_file_system()