ExternalVendorCode/sondehub-infra
1
0
Fork 0
mirror of https://github.com/projecthorus/sondehub-infra.git synced 2025-04-07 11:08:27 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

adjust resolutions, timeouts and max time

Browse Source
This commit is contained in:
Michaela 2021-07-19 11:10:14 +10:00
parent a3159854cc
commit 8e03e43ca7
2 changed files with 12 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
main.tf
View File

@ -625,7 +625,7 @@ resource "aws_lambda_function" "datanew" {
filename = "${path.module}/build/query.zip"
source_code_hash = data.archive_file.query.output_base64sha256
publish = true
memory_size = 256
memory_size = 1024
role = aws_iam_role.IAMRole5.arn
runtime = "python3.7"
timeout = 30

18
query/lambda_function.py
View File

@ -124,6 +124,7 @@ def get_telem(event, context):
path = "telm-*/_search"
payload = {
"timeout": "30s",
"aggs": {
"2": {
"terms": {
@ -191,10 +192,10 @@ def get_telem(event, context):
def datanew(event, context):
durations = { # ideally we shouldn't need to predefine these, but it's a shit load of data and we don't need want to overload ES
"3days": (259200, 1200), # 3d, 20m
"1day": (86400, 600), # 1d, 10m
"12hours": (43200, 300), # 12h, 2m
"6hours": (21600, 120), # 6h, 1m
"3days": (259200, 1800), # 3d, 20m
"1day": (86400, 900), # 1d, 10m
"12hours": (43200, 480), # 12h, 2m
"6hours": (21600, 180), # 6h, 1m
"3hours": (10800, 90), # 3h, 10s
"1hour": (3600, 30), # 1h, 5s
}
@ -231,14 +232,14 @@ def datanew(event, context):
matched_time = matches[1].replace("Z", "+00:00")
matched_vehicle = matches[0]
requested_time = datetime.fromisoformat(matched_time)
lt = requested_time
lt = requested_time + timedelta(seconds=duration)
gte = requested_time
else:
requested_time = datetime.fromisoformat(
event["queryStringParameters"]["position_id"].replace("Z", "+00:00")
)
lt = datetime.now(timezone.utc)
lt = requested_time + timedelta(seconds=duration)
gte = requested_time
elif event["queryStringParameters"]["mode"] == "single":
@ -250,6 +251,7 @@ def datanew(event, context):
if "chase_only" not in event["queryStringParameters"] or event["queryStringParameters"]["chase_only"] != "true":
path = "telm-*/_search"
payload = {
"timeout": "30s",
"aggs": {
"2": {
"terms": {
@ -397,6 +399,7 @@ def datanew(event, context):
# get chase cars
payload = {
"timeout": "30s",
"aggs": {
"2": {
"terms": {
@ -506,6 +509,7 @@ def get_listeners(event, context):
path = "listeners-*/_search"
payload = {
"timeout": "30s",
"aggs": {
"2": {
"terms": {
@ -630,7 +634,7 @@ if __name__ == "__main__":
{
"queryStringParameters": {
"type": "positions",
"mode": "12hours",
"mode": "3hours",
"position_id": "0",
"vehicles": "T1240847"
}