Skip to content

Commit

Permalink
fix
Browse files Browse the repository at this point in the history
  • Loading branch information
badra001 committed Apr 26, 2023
1 parent cfe7dea commit 5fa9aaf
Show file tree
Hide file tree
Showing 2 changed files with 12 additions and 13 deletions.
25 changes: 12 additions & 13 deletions code/ddns-lambda.py
Original file line number Diff line number Diff line change
Expand Up @@ -386,7 +386,7 @@ def lambda_handler(
instance = remove_empty_from_dict(instance)
instance_dump = json.dumps(instance, default=json_serial)

# dont' change to dictionary. Keep it as string to be written to DDB
# don't change to dictionary. Keep it as string to be written to DDB
# instance_attributes = json.loads(instance_dump)
instance_attributes = instance_dump
LOGGER.info("instance_attributes: %s", str(instance_attributes) + lineno())
Expand All @@ -403,9 +403,9 @@ def lambda_handler(
instance = get_item_from_dynamodb_table(dynamodb_client, DDBNAME, instance_id)
LOGGER.info("instance attributes: %s", str(instance) + lineno())
try:
## LOGGER.info(f"instance_data type {type(instance)} {lineno()}")
## instance_data = json.loads(instance)
## LOGGER.info(f"getting _DnsEntries {lineno()}")
# LOGGER.info(f"instance_data type {type(instance)} {lineno()}")
# instance_data = json.loads(instance)
# LOGGER.info(f"getting _DnsEntries {lineno()}")
dns_data_raw = instance.get('_DnsEntries', [])
LOGGER.info(
f"got _DnsEntries type {type(dns_data_raw)} value {dns_data_raw} {lineno()}")
Expand Down Expand Up @@ -1036,9 +1036,8 @@ def lambda_handler(
put_item_in_dynamodb_table(
dynamodb_client, DDBNAME, instance_id, instance_attributes)
LOGGER.debug(f"Done updating item in dynamodb table {lineno()}")
except Exception as err:
LOGGER.error(
f"Error putting item in DDB table {instance_id} error {err} {lineno()}")
except Exception as err:
LOGGER.error(f"Error putting item in DDB table {instance_id} error {err} {lineno()}")

# Clean up DynamoDB after deleting records
if state != 'running':
Expand All @@ -1060,7 +1059,7 @@ def lambda_handler(
caller_response.insert(0, 'Successfully created recordsets')

LOGGER.info(f"dns_data records written:\n{pformat(dns_data)}")
## put_instance_dns_data_item(dynamodb_client, DDBNAME, instance_id, dns_data)
# put_instance_dns_data_item(dynamodb_client, DDBNAME, instance_id, dns_data)

count['end'] = datetime.datetime.now()
count['elapsed_ms'] = (count['end'] - count['start']).total_seconds() * 1000.0
Expand All @@ -1070,13 +1069,13 @@ def lambda_handler(


# def put_instance_dns_data_item(dynamodb_client, DDBNAME, instance_id, dns):
## dns_list = [dict(d._asdict()) for d in dns]
# dns_list = [dict(d._asdict()) for d in dns]
# dns_info = json.dumps(dns_list, default=json_serial)
## dns_info = json.dumps(dns_list)
# dns_info = json.dumps(dns_list)
##
## LOGGER.debug(f"put dns data into {instance_id}/dns: {str(dns_info)}: {lineno()}")
## put_item_in_dynamodb_table(dynamodb_client, DDBNAME, f'{instance_id}/dns', dns_info)
## LOGGER.debug(f"done putting dns item in dynamo table {lineno()}")
# LOGGER.debug(f"put dns data into {instance_id}/dns: {str(dns_info)}: {lineno()}")
# put_item_in_dynamodb_table(dynamodb_client, DDBNAME, f'{instance_id}/dns', dns_info)
# LOGGER.debug(f"done putting dns item in dynamo table {lineno()}")
# return


Expand Down
Binary file modified code/ddns-lambda.zip
Binary file not shown.

0 comments on commit 5fa9aaf

Please sign in to comment.