Tools for handling appsync responses.
Project description
appsync-tools
Parses aurora and dynamodb responses into a more usable format.
Aurora results are returned as a list of dictionaries with the column names being the key. Nulls (returned by Aurora as isNull) are returned as None types. Any value that can be parsed as json is cast from a string to a list/dictionary. Responses are returned formated as:
[
{"columnOneName": "value", "columnTwoName": "value"},
{"columnOneName": "value", "columnTwoName": "value"}
]
Where each item in the top level array is a separate row.
Dynamodb results are returned as either a dictionary (for get_item operations) or a list of dictionaries (query).
Pretty parsing Aurora records
pretty_parse_aurora(records, type_attribute=None) -> list
Arguments:
- records -- The records from the API query (execute_statement()["records"])
Keyword Args:
- type_attribute -- If used will pass results to typify(results, type_attribute=type_attribute) before returning
from appsync_tools import pretty_parse_aurora
response = client.execute_statement(
secretArn=environ["PG_SECRET"],
database=environ["DB_NAME"],
parameters=parameters,
resourceArn=environ["DB_ARN"],
includeResultMetadata=True,
sql=sql
)
print(pretty_parse_aurora(response))
Parsing Dynamodb records
pretty_parse_dynamo(records, type_attribute=None) -> list | dict
Arguments:
- records -- The Item(s) from a call to query, get_item
Keyword Args:
- type_attribute -- If used will pass results to typify(results, type_attribute=type_attribute) before returning
from appsync_tools import pretty_parse_dynamo
response = client.get_item(
Key={"pk": "foo", "sk": "bar"}
)
print(response.get("Item"))
Adding __typename to all records based on an attribute
typify(records, type_attribute="type") -> list | dict Arguments: records -- The Item(s) from a call to query, get_item Keyword Args: type_attribute -- Attribute name that contains the __typename value
Example
from appsync_tools import typify
response = client.get_item(
Key={"pk": "foo", "sk": "BarType"}
)
print(typify(response.get("Item"), type_attribute="sk"))
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
Built Distribution
Hashes for appsync_tools-1.0.2-py2.py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 32fd31d2035bb512f1f1846abbe52eba4fce8a0054f8787d3e0dd46ecfffa1c3 |
|
MD5 | 2244f20094f75c65e39a98225c21781b |
|
BLAKE2b-256 | 22a997c72cabde69122a0ff9b9710a762d644a8a0eceb6175e417cbba0e7d045 |