snowflake_hook.py 文件源码

def get_pandas_df(self, sql):
        """
        We need to overide this method in order to use connections other than the default_conn_name
        :param sql: A query input via the web UI at /admin/queryview/
        :return: a Panda data frame
        """
        conn = self.get_conn(self.snowflake_conn_id)
        df = pd.read_sql_query(sql, conn)
        return df