Importa en la librería el mecanismo de stores que estamos usando en varias ETLs:
Propone una interfaz común Store para almacenar entidades NGSIv2 en backends genéricos. La interfaz consiste en un solo método con un solo parámetro, entities.
Implementa dos Stores ajustados a la interfaz:
orionStore que escribe las entidades a un cbManager con send_batch
sqlFileStore que escribe las entidades a un fichero SQL. Añade una dependencia a la librería psycopg2-binary
arcosa
commented
1 year ago
Importa en la librería el mecanismo de
storesque estamos usando en varias ETLs:Storepara almacenar entidades NGSIv2 en backends genéricos. La interfaz consiste en un solo método con un solo parámetro,entities.Stores ajustados a la interfaz:orionStoreque escribe las entidades a uncbManagerconsend_batchsqlFileStoreque escribe las entidades a un fichero SQL. Añade una dependencia a la libreríapsycopg2-binary