Skip to main content

This is a 3TL module for pipeline creation

Project description

### step class ###

step class consist common functions which can be inherited by other classes – setTaskID, setUUID,setTaskExecutionID,startRedisConn,setLogger,loadParams,connectToAPIForKey,createAndGetResponseFromURL,getLogger,exceptionTraceback,getRelativeFile;

### extract class###

extract class consist of init method which sets all loadParams and log files .. also contains super class startup which can be defined from client extract .. it also consist of startWs- starting websocket connection functions .;

### ML class ###

Ml class consist of startup method ,startMLSubscriber to subscribr to the incoming data ,process ml to process data , compute ml to do client ML computations and handoff it to next step;

### Transform class ###

Transform class consist of startup ,startTRSubscriber to subscribr to the incoming data , tranformExData -function has to be defined inside clientTranform with own tranform logic .It also consist of microBatchProcessRedisSortedSet for microbatching streaming data ./;

### Load Class ###

Load class consist of startup method , loadsubscribers to listen to the data and client logic to loading final data needs to be added in client load file;

### New Release Note version=’0.1.34’ ###

### Connectors Added ###

AzBlob Read (Azure Blob) Using this connector you can read file from AzBlob; for Azure Blob Read connection , create sorce folder inside params and add spec.json with connection configs ;

AzBlob Write(Azure Blob) Using this connector you can write file to AzBlob; for Azure Blob Write connection , create destination folder inside params and add spec.json with connection configs ;

SFTP Read Using this connector you can read file from SFTP server ; for SFTP connection , create source folder inside params and add spec.json with connection configs ;

SFTP Write Using this connector you can read file to SFTP server for SFTP Write connection , create destination folder inside params and add spec.json with connection configs ;

Postgres Read Using this connector you can read file from Postgres database;

Postgres Write Using this connector you can read file to Postgres database;

IPFS source you can use this connector to read file from any IPFS http url, check() function checks connection setup. this connector contains read function which will return data in bytes format;

IPFS destination this connector helps you to upload any file on customIPFS node, check() function checks connection setup, write() function in this connector uses file and target location as input and will return json consisting contentId ,name and size of file;

Mysql source Source connector for MySQL database using SQLAlchemy. check() function is used to check if the database connection, discover() function is used to discover the tables in the database Read from the connected database.

Mysql destination check() function is used to check if the database connection, get_table() function is used to get the table object from the database,write()function is used to write data to the database. License-File: LICENSE.txt

Project details


Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

libs3tl-0.1.45.tar.gz (22.2 kB view hashes)

Uploaded Source

Supported by

AWS AWS Cloud computing and Security Sponsor Datadog Datadog Monitoring Fastly Fastly CDN Google Google Download Analytics Microsoft Microsoft PSF Sponsor Pingdom Pingdom Monitoring Sentry Sentry Error logging StatusPage StatusPage Status page