Как подключить Mysql к облачным функциям? ⇐ Python

[Anonymous]

Внутри облачных функций у меня есть эти функции (точка входа)

Код: Выделить всё

def hello_http(request):

Внутри этой функции у меня есть весь этот код
Что он делает: загружает таблицу цен, например btc_usd, а затем помещает этот фрейм данных в базу данных Google mysql
Данные база размещена внутри GCP.
Чтобы вызвать эту функцию, я использую http
А затем в облачном планировщике я вставил URL-адрес с помощью метода POST

Код: Выделить всё

import pandas as pd
import requests
import sqlalchemy
import mysql.connector
import pandas as pd
import numpy as np
import requests

class BitsoAPI:
def __init__(self, api_key, api_secret):
self.api_key = api_key
self.api_secret = api_secret
self.base_url = "https://api.bitso.com/v3/"

def get_daily_prices(self, book="btc_usd"):
response = requests.get('https://api.bitso.com/v3/trades/?book='+book)
json_response = response.json()
datos = json_response['payload']
df = pd.DataFrame(datos)
df['fecha'] = pd.to_datetime(df['created_at'],utc=True, format='ISO8601')
del df['created_at']
return df

def get_books(self):
'''Returns a list with names of avaiable books for book parameter from
get daily prices function'''
response = requests.get(self.base_url + 'available_books/')
json_response = response.json()
books = [book['book'] for book in json_response['payload']]
return books

def store_data_in_sql(df, table_name='ok'):
# Establish connection to MySQL database
connection = mysql.connector.connect(
host=db_host,
user=db_user,
password=db_password,
database=db_name
)

# Create MySQL cursor
cursor = connection.cursor()

# Insert the DataFrame into the MySQL table
df.to_sql(table_name, con=engine, if_exists='append', index=False)

# Commit changes and close connection
connection.commit()
connection.close()

for book in books:
bitso_api = BitsoAPI(api_key, api_secret)
df = bitso_api.get_daily_prices(book=book)
store_data_in_sql(df,table_name=book)

Но потом каждый раз, когда я запускал ее в планировщике, получал сообщение «Ошибка», хотя я мог создать функцию в облачных функциях

Подробнее здесь: https://stackoverflow.com/questions/784 ... -functions