Cloud FunctionsからGCSへredashの抽出結果を定時アップロードしたい

Question

前提・実現したいこと

Google Cloud FunctionsからGCSへredashのクエリ抽出結果（redash_dynamic_queryを使用）をアップロードしたいのですが、上手く行きません。

最終的には、Google Cloud Functions（トリガー:pub/sub)でredashクエリ結果を抽出するのを、Cloud Schedulerで定期実行させたい形です。
アップロードの際に他に何か必要な事があるのか（設定で書き込み不可になっているなど）、それともそもそもコードがおかしいのか調べても情報がうまく得られず、悩んでおります。ご助言頂けないでしょうか。

該当のソースコード

from redash_dynamic_query import RedashDynamicQuery
import pandas as pd
import json
from google.cloud import storage as gcs

def upload_blob(bucket_name, destination_blob_name, flg_index=False, flg_header=True):
    redash = RedashDynamicQuery(
    endpoint='https://redash.xxx.com/',
    apikey='[api_key]',
    max_wait=5000,
    )
    query_id = 1200
    bind = {
    "start_date":  '2021-06-01T00:00:00',
    "end_date":  '2021-06-07T23:59:59',
    }

    #redashのクエリ結果を取得
    result = redash.query(query_id, bind)
    res = result['query_result']['data']

    #jsonを整形
    res_format_json = json.dumps(res, indent=4, separators=(',', ': '))

    #json形式でエラーが出るため、一時tmpへ退避
    f = open('/tmp/'+'output.json', 'w')
    t = 'output.json'
    shutil.copy2(user_secret_file, f)
    json.dump(res['rows'], t)

    #変換したいjsonファイルを読込
    df = pd.read_json("output.json")
    """Uploads a file to the bucket."""
    # The ID of your GCS bucket
    bucket_name = "[bucket_name]"
    # The ID of your GCS object
    destination_blob_name = "testQuery_2021_05_11.csv"

    storage_client = storage.Client()
    bucket = storage_client.bucket(bucket_name)
    blob = bucket.blob(destination_blob_name)
    blob.upload_from_string(df.to_csv(index=flg_index, header=flg_header, sep=","))

redash-dynamic-query==1.0.4
pandas
google-cloud-storage==1.23.0

試したこと

・ローカルでquery_id = 1200のクエリがDataFrame形式で抽出出来たのは確認。
・アップロードの部分だけ試そうと以下のコードを実行したのですが、今度は「NameError: name 'gcs' is not defined」などが出てくる次第です。

import pandas as pd
from google.cloud import storage as gcs

def hello_pubsub(a,b):
    project_id = "My First Project"
    bucket_name = "[バケット名]"
    gcs_path = "[ファイルパス]"

    client = gcs.Client(project_id)
    bucket = client.get_bucket(bucket_name)

    # 格納するGCSパスを指定
    blob = bucket.blob(gcs_path)

    df = pd.DataFrame([[1,2,3],[5,6,7]],columns=["x","y","z"])
    # DataFrameをGCSにUpload
    blob.upload_from_string(df.to_csv(index=flg_index, header=flg_header, sep=","))

    print(
        "File {} uploaded to {}.".format(
            source_file_name, destination_blob_name
        )
    )

pandas
google-cloud-storage==1.23.0

補足情報（FW/ツールのバージョンなど）

ここにより詳細な情報を記載してください。