Senior Data Engineer
CurrentResponsibilities: • Involved in building scalable distributed data lake system for confidential real time and batch analytical needs. • Worked on data processing and transformations and actions in spark by using Python (PySpark) language. • Provisioning and configuring EC2 instances, S3 buckets, and other AWS services for data storage, processing, and analytics. • Developing and deploying serverless functions using AWS Lambda and API Gateway for real-time data… Show more Responsibilities: • Involved in building scalable distributed data lake system for confidential real time and batch analytical needs. • Worked on data processing and transformations and actions in spark by using Python (PySpark) language. • Provisioning and configuring EC2 instances, S3 buckets, and other AWS services for data storage, processing, and analytics. • Developing and deploying serverless functions using AWS Lambda and API Gateway for real-time data processing and analytics. • Building and deploying data pipelines using AWS Glue, AWS Data Pipeline, and Amazon Kinesis for batch and real-time data ingestion and processing. • Wrote and executed various MYSQL database queries from Python using Python-MySQL connector and MySQL DB package. • Development level experience in Microsoft Azure providing data movement and scheduling functionality to cloud-based technologies such as Azure Blob Storage and Azure SQL Database. • Setting up and configuring Snowflake accounts, warehouses, and databases for storing and processing data. • Developing and deploying ETL pipelines using Snowflake and tools such as Talend or Modillion for moving and transforming data • Migrating data from Oracle to Data Lake using Sqoop, Spark. • Developed Scala scripts, UDFs using both Data frames/SQL and RDD in Spark 2.4 for Data Aggregation, queries and writing data back into OLTP system through Sqoop. • Implement HIVE UDF’s for evaluation, filtering, loading, and storing of data. • Experienced in handling large datasets using partitions, Spark in Memory capabilities, Broadcasts in Spark, Effective & efficient Joins, Transformation and other during ingestion process itself. • Worked on a POC to compare processing time for Impala with Apache Hive for batch applications to implement the former in project. • Developed logical and physical data models that capture current state/future state data elements and data flows. Show less