在snowflakeconnector中使用pd_writer方法运行时发生NameError（“未定义名称“引擎”）

Question

"""Module for acquiring Raw blast Data"""
from simple_salesforce import Salesforce
import sys
import pandas
import pytz
from datetime import datetime,date
import snowflake
from sqlalchemy import create_engine
from snowflake.connector.pandas_tools import pd_writer
import boto3


    def sf_To_df(self):
        sf_data = self.salesForceAuth.query_all(self.queryColumns)
        sf_data=dict(sf_data)
        try:            
            cursor=snowflake.connector.connect(user=snowflake_user_path,password=snowflake_secret_path,account=snowflake_account,warehouse=snowflake_warehouse,database=snowflake_database,schema=snowflake_schema);

            for dictKey1, dictValue1 in sf_data.items():
                if dictKey1 == "records":
                    sf_Df = pandas.DataFrame.from_records(dictValue1)
                    **sf_Df.to_sql(dictKey1, engine, index=False, method=pd_writer)**
            
        except Exception as e:
            typ, obj, tb = sys.exc_info()
            print("exception while reading the key value: ", e.__repr__(),tb.tb_lineno)

Answer 1

引擎是你的连接

def sf_To_df(self):
    sf_data = self.salesForceAuth.query_all(self.queryColumns)
    sf_data=dict(sf_data)
    try:            
        cursor=snowflake.connector.connect(user=snowflake_user_path,password=snowflake_secret_path,account=snowflake_account,warehouse=snowflake_warehouse,database=snowflake_database,schema=snowflake_schema);

    for dictKey1, dictValue1 in sf_data.items():
        if dictKey1 == "records":
            sf_Df = pandas.DataFrame.from_records(dictValue1)
            **sf_Df.to_sql(dictKey1, cursor, index=False, method=pd_writer)**
    
except Exception as e:
    typ, obj, tb = sys.exc_info()
    print("exception while reading the key value: ", e.__repr__(),tb.tb_lineno)