make it compatible with local

hydrocronapi/controllers/db/db.py

@@ -7,9 +7,17 @@
 from typing import Generator
 from boto3.dynamodb.conditions import Key
 import boto3
+import os
+
+if os.environ['environment'] == 'local':
+    dynamodb_resource = boto3.resource('dynamodb',
+                              aws_access_key_id="a",
+                              aws_secret_access_key="a",
+                              region_name="us-west-2",
+                              endpoint_url="http://localhost:8000")
+else:
+    dynamodb_resource = boto3.resource('dynamodb')
 
-dynamodb = boto3.client('dynamodb')
-dynamodb_resource = boto3.resource('dynamodb')
 table = dynamodb_resource.Table('hydrocron_swot_reaches_test')
 
 logger = logging.getLogger()

hydrocronapi/swagger/swagger.yaml

@@ -53,7 +53,7 @@ paths:
         schema:
           type: string
           format: date-time
-        example: 2022-08-23T00:00:00Z
+        example: 2023-08-23T00:00:00Z
       - name: output
         in: query
         description: Format of the data returned
@@ -153,7 +153,7 @@ paths:
         schema:
           type: string
           format: date-time
-        example: 2022-08-23T00:00:00Z
+        example: 2023-08-23T00:00:00Z
       - name: output
         in: query
         description: Format of the data returned

tests/example_load_data.py

@@ -0,0 +1,30 @@
+import boto3
+import geopandas as gpd
+import json
+from decimal import Decimal
+
+def upload():
+    table = boto3.resource('dynamodb',
+                          aws_access_key_id="a",
+                          aws_secret_access_key="a",
+                          region_name="us-west-2",
+                          endpoint_url="http://localhost:8000").Table('hydrocron_swot_reaches_test')
+
+    test_shapefile_path = 'tests/data/SWOT_L2_HR_RiverSP_Reach_548_011_NA_20230610T193337_20230610T193344_PIA1_01/SWOT_L2_HR_RiverSP_Reach_548_011_NA_20230610T193337_20230610T193344_PIA1_01.shp'
+
+    shp_file = gpd.read_file(test_shapefile_path)
+
+    item_attrs = {}
+    for index, row in shp_file.iterrows():
+        attributes = json.loads(row.to_json(default_handler=str), parse_float=Decimal)
+        for k,v in attributes.items():
+            if (str(k)=="time"):
+                item_attrs[k] = Decimal(v)
+            else:
+                item_attrs[k] = str(v)
+            print(str(k),str(v))
+
+        table.put_item(Item=item_attrs)
+
+upload()
+