okr_kd/test.py

import time
import schedule
from datetime import datetime, timedelta

from functions.odps_function import OdpsFunction


def read_odps_data(date_info):
    """
    从 odps 读取数据
    :return:
    """
    o = OdpsFunction()
    sql = f"""select * from loghubods.okr_kd where dt = '{date_info}';"""
    data = o.select(sql)
    return data


w = read_odps_data("20240403")
print(len(w))
print(w)