aboutsummaryrefslogtreecommitdiffstats
path: root/tests/test_load_lambda.py
diff options
context:
space:
mode:
authorEllie <ecsymonds@gmail.com>2024-08-23 12:38:25 +0100
committerEllie <ecsymonds@gmail.com>2024-08-23 12:38:25 +0100
commitf3bb705a31ab9d94dc856c2de0da4b7b73a57fae (patch)
tree67e25c4561d7c8ab5cb0fbd0674fc4bc1201adfd /tests/test_load_lambda.py
parent65289cdd17359c6a29560339e134e0ddf9461ce0 (diff)
downloadde-project-bentley-f3bb705a31ab9d94dc856c2de0da4b7b73a57fae.tar.gz
de-project-bentley-f3bb705a31ab9d94dc856c2de0da4b7b73a57fae.zip
add get transform bucket test
Diffstat (limited to 'tests/test_load_lambda.py')
-rw-r--r--tests/test_load_lambda.py48
1 files changed, 44 insertions, 4 deletions
diff --git a/tests/test_load_lambda.py b/tests/test_load_lambda.py
index d9ea918..2392f10 100644
--- a/tests/test_load_lambda.py
+++ b/tests/test_load_lambda.py
@@ -1,8 +1,48 @@
import pandas as pd
import pyarrow.parquet as pq
from io import BytesIO
-from src.load_lambda import convert_parquet_files_to_dfs
+from moto import mock_aws
+import boto3
+import os
+import pytest
+from src.load_lambda import lambda_handler, connect_to_db_and_return_engine, get_transform_bucket, convert_parquet_files_to_dfs, upload_dfs_to_database
-class TestConvertParquetToDFs:
- def test_convert_parquet_to_dfs_returns_df():
- \ No newline at end of file
+@pytest.fixture(scope="class")
+def aws_credentials():
+ os.environ["AWS_ACCESS_KEY_ID"] = "testing"
+ os.environ["AWS_SECRET_ACCESS_KEY"] = "testing"
+ os.environ["AWS_SECURIT_TOKEN"] = "testing"
+ os.environ["AWS_SESSION_TOKEN"] = "testing"
+ os.environ["AWS_DEFAULT_REGION"] = "eu-west-2"
+
+
+@pytest.fixture(scope="class")
+def s3_client(aws_credentials):
+ with mock_aws():
+ yield boto3.client("s3")
+
+@pytest.fixture(scope="function")
+def s3_mock_bucket(s3_client):
+ bucket = s3_client.create_bucket(
+ Bucket="transform_bucket",
+ CreateBucketConfiguration={"LocationConstraint": "eu-west-2"},
+ )
+ return bucket
+
+
+class TestLambdaHandler:
+ pass
+
+class TestConnectToDBAndReturnEngine:
+ pass
+
+class TestGetTransformBucket:
+ def test_get_transform_bucket_returns_string(self, s3_client, s3_mock_bucket):
+ result = get_transform_bucket(s3_client)
+ assert result == "transform_bucket"
+
+class TestConvertParquetToDfs:
+ pass
+
+class TestUploadDfsToDatabase:
+ pass \ No newline at end of file
git.ajschof.me — hosted by ajschofield — powered by cgit