You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
|`backend`|**Imms API** – Handles CRUD operations for the Immunisation API. |
22
-
|`delta_backend`|**Imms Sync** – Lambda function that reacts to events in the Immunisation database. |
23
-
|`ack_backend`|**Imms Batch** – Generates the final Business Acknowledgment (BUSACK) file from processed messages and writes it to the designated S3 location. |
|`ack_backend`|**Imms Batch** – Generates the final Business Acknowledgment (BUSACK) file from processed messages and writes it to the designated destination. |
22
+
|`backend`|**Imms API** – Handles CRUD operations for the Immunisation API. |
23
+
|`batch_processor_filter`|**Imms Batch** – Controller function that consumes from a queue and forwards file event for processing if filter conditions are met. |
24
+
|`delta_backend`|**Imms Sync** – Lambda function that reacts to events in the Immunisation Event Data Store (IEDS). |
25
+
|`filenameprocessor`|**Imms Batch** – Validates and processes new batch file events. |
26
+
|`id_sync`|**Imms Cross-cutting** – Handles [MNS](https://digital.nhs.uk/developer/api-catalogue/multicast-notification-service) NHS Number Change events and applies updates to affected records. |
27
+
|`mesh_processor`|**Imms Batch** – Triggered when new files are received via MESH. Moves them into the Imms Batch processing system. |
28
+
|`mns_subscription`|**Imms Cross-cutting** – Simple helper Lambda which sets up our required MNS subscription. Used in pipelines in DEV. |
29
+
|`recordforwarder`|**Imms Batch** – Consumes from the stream and applies the processed batch file row operations (CUD) to IEDS. |
30
+
|`recordprocessor`|**Imms Batch** – ECS Task - **not** a Lambda function - responsible for processing batch file rows and forwarding to the stream. |
31
+
|`redis_sync`|**Imms Cross-cutting** – Handles config file updates. E.g. disease mapping or permission files. |
32
+
|`shared`|**Imms Cross-cutting** – Shared `common` code that can be shared by other Lambda functions. This is not a standalone Lambda. |
|`azure`| Pipeline definition and orchestration code. |
38
+
Due to the timing of the project's inception, Azure pipelines have been inherited from the API Management team for deploying
39
+
the Apigee proxy and sandbox. The new way to manage and deploy said resources is [Proxygen](https://digital.nhs.uk/developer/api-catalogue/proxy-generator).
40
+
41
+
In future a migration plan will be provided by the API Management team so we can move to the new process and use purely
## AWS configuration: Getting credentials for AWS federated user account
273
-
274
-
In the 'Access keys' popup menu under AWS Access Portal:
275
-
276
-
**NOTE** that AWS's 'Recommended' method of getting credentials **(AWS IAM Identity Center credentials)** will break mocking in unit tests; specifically any tests calling `dynamodb_client.create_table()` will fail with `botocore.errorfactory.ResourceInUseException: Table already exists`.
277
-
278
-
Instead, use **Option 2 (Add a profile to your AWS credentials file)**.
|**`converter.py`**|🧠 The main brain — applies the schema, runs conversions, handles errors. |
11
+
|**`converter.py`**| The main brain — applies the schema, runs conversions, handles errors.|
12
12
|**`conversion_layout.py`**| A plain Python list that defines which fields you want, and how they should be formatted (e.g. date format, renaming rules). |
13
-
|**`delta.py`**| Holds the function called by AWS Lambda|
13
+
|**`delta.py`**| Holds the function called by AWS Lambda.|
14
14
|**`extractor.py`**| Tailored functionality to extract target fields from immunization record received by the delta handler. |
15
15
|**`exception_messages.py`**| Holds reusable error messages and codes for clean debugging and validation feedback. |
Copy file name to clipboardExpand all lines: lambdas/id_sync/README.md
+2-2Lines changed: 2 additions & 2 deletions
Display the source diff
Display the rich diff
Original file line number
Diff line number
Diff line change
@@ -2,12 +2,12 @@
2
2
3
3
## Overview
4
4
5
-
**Id Sync** is an AWS Lambda function designed to trigger from SQS. It receives a list of NHS Numbers and checks for changes in PDS. If change found, it updates the Events Table..
5
+
**Id Sync** is an AWS Lambda function designed to trigger from SQS. It receives a list of NHS Numbers and checks for changes in PDS. If change found, it updates the Events Table.
6
6
7
7
## Features
8
8
9
9
-**SQS Event Driven:** Automatically triggered by SQS event.
10
-
-**DynamoDb Integration:** Reviews contents of DynbamoDb Events table and updates where required..
10
+
-**DynamoDb Integration:** Reviews contents of DynamoDb Events table and updates where required.
11
11
-**Logging:** Provides detailed logging for monitoring and troubleshooting.
0 commit comments