Action Custom avec une source Connectors directement

import sys
from forepaas.dwh.connect import connect
from forepaas.dwh import bulk_insert
import logging

logger = logging.getLogger(__name__)

def customfunc(event):
    try:
        # ici, on se connecte à une source nommée 'chicago_files'
        source_address = "dwh/chicago_files_artur/"

        # spécifie le nom de fichier non pris en charge dans la liste des fichiers de la source
        filename_w_extension = "stations_rides.csv"

        # se connecte au fichier pour obtenir l'adresse 
        source_file_connector = connect(source_address + filename_w_extension) 

        # se connecte directement au fichier
        file_address = source_file_connector.get()
        file_connector = connect(file_address) 

        # extrait et traite le fichier pour le rendre utilisable
        df = file_connector.extract(return_type='dataframe') 

        # traite les données
        # - - - - 

        # se connecte au Lakehouse Manager
        dm_connector = connect("dwh/default_dataset/")

        # insère dans une table de destination existante
        stats = bulk_insert(dm_connector, "chicago_calendar_full", df) 

        logger.info(stats)

        # se déconnecte du datastore et de la source distante
        del source_connector
        del dm_connector

    except Exception as err:
            raise Exception(f"err:{err} L:{sys.exc_info()[2].tb_lineno}")