andreani-aa-tools 0.0.15

Common functions and protocols used by the Andreani Advanced Analytics team

Andreani Advanced Analytics tools

Instalar usando pip

pip install andreani-aa-tools

Importación

import aa_tools

Ejemplo de uso

• Haversine

from aa_tools import logger, haversine

if __name__ == "__main__":

    log = logger("test.py", "main")

    result = haversine(-58.490160, -34.566116, -58.485096, -34.572123)

    log.log_console(f"Haversine distance: {result}", "INFO")

    log.close()

• Apply Parallel

from aa_tools import applyparallel

def func(row):
    return row['A'] + row['B'] 

def func_2(row, nro):
    return row['A'] * nro

df['C'] = df.apply_parallel(func, num_processes=4)
df['D'] = df.apply_parallel(func_2, nro=5)

Listado de funciones agregadas:

• Haversine: Distancia euclidia entre dos puntos.

• Logger: Maneja el log según los lineamientos de Andreani.

• Datalake: Interfaz de conexión al datalake para descargar y cargar archivos csv, parquet y/o json.

Listado de funciones a agregar:

• División de un dataframe en una lista de dataframes para procesamiento en hilos.

• Distancia de ruta entre dos puntos.

• Model training