data etl for AWS Personalize

personalize_etl.py

def etl_user() -> None: 
  df = pd.read_sql_table("데이터베이스 테이블 이름") 
  df_selected = df.reset_index()[['user_id', 'age', 'os_device']] 
  # 이 부분에서 user_schema.json 에 정의한 내용대로 
  # dataframe의 column 이름, type을 맞춰줘야합니다. 
  # 이후 S3에 csv 형태로 저장합니다. 
  df.to_csv(USER_S3_PATH) 
  
def etl_item(): 
  df = pd.read_sql_table("데이터베이스 테이블 이름") 
  # 이 부분에서 item_schema.json 에 정의한 내용대로 
  # dataframe의 column 이름, type을 맞춰줘야합니다. 
  # 이후 S3에 csv 형태로 저장합니다. 
  df.to_csv(ITEM_S3_PATH) 
  return item_df['item_id'].tolist() 

def etl_event(common_list) -> None: 
  df = pd.read_sql_table("데이터베이스 테이블 이름") 
  # 이 부분에서 event_schema.json 에 정의한 내용대로 
  # dataframe의 column 이름, type을 맞춰줘야합니다. 
  # 이후 S3에 csv 형태로 저장합니다. 
  pip_df.to_csv(EVENT_S3_PATH)