Action Custom avec des tables du Lakehouse Manager

import sys
import pandas as pd
import logging

from forepaas.dwh import connect
from forepaas.dwh import bulk_insert

logger = logging.getLogger(__name__)
def customfunc(event):
    try:
        logger.notice("Begin function")

        # établit la connexion au dataset par défaut
        cn = connect("dwh/default_dataset/")

        # option 1 : extrait les données de la table sans SQL requis
        df = cn.select("stations_rides")

        # option 2 : extrait les données avec du SQL personnalisé
        df = cn.query("SELECT station_id, date, rides, station_name FROM stations_rides")

        # effectue votre transformation personnalisée dans le dataframe
        df.loc[df["station_name"] == 'Harlem-Lake', "rides"] = 0

        # réinsère votre dataframe dans la table de destination
        stats = bulk_insert(cn, "stations_rides", df) 

        # affiche les statistiques d'insertion (si le SGBD le permet) 
        logger.info(stats)

        # supprime les lignes où le nom de la station est "Davis"
        cn.delete("stations_rides", {"station_name":"Davis"})

        # met à jour les lignes en définissant rides à 0 où station_id=40040
        cn.update("stations_rides", {"rides":0}, {"station_id":40040})

        # une fois terminé, déconnecte cn
        del cn    
        logger.notice("END function")
    except Exception as err: 
        raise Exception("err:{} L:{}".format(err,sys.exc_info()[2].tb_lineno))