S3 Trigger to push files to PHA / Health Care Centers.
- Java 17 or Higher
- AWS SDK - STS or Eclipse
- AWS Account
- Maven 3.3.x
- GIT
Clone the repository using the below command in command prompt
`git clone https://github.com/drajer-health/ecr-pha-processor-lambda.git
Import Project as Maven Project Build:
Navigate to ecr-pha-processor-lambda
directory ..../
and run Maven build to build lambda jar file.
$ mvn clean install
This will generate a war file under target/ecr-pha-processor-lambda-1.0.0.jar.
Login to your AWS Account
-
Click on Services then select Lambda
-
Click on Create Function
-
Select "Author from Scratch" option
-
Enter:
Function Name: ecr-PHA-Processor-lambda
Runtime: Java 17
Permissions: Create a new role with basic Lambda permissions or select your organization specific security
- Click on "Create Function"
At this point Lambda function would be created, navigate to the newly created function and configure the lambda function and environment variable.
-
Go to the newly created Role.
-
Under
Permissions
tab click onCreate inline Policy
-
Click on
{ } JSON
tab and ad the following security policy. Replace theS3-BUCKET-NAME
with your S3 name.
{
{
"Version": "2012-10-17",
"Statement": [
{
"Sid": "ListObjectsInBucketS3",
"Effect": "Allow",
"Action": [
"s3:GetObjectVersion",
"s3:GetBucketLocation",
"s3:GetObject",
"s3:PutObject",
"s3:PutObjectAcl"
],
"Resource": "arn:aws:s3:::S3-BUCKET-NAME/*"
}
]
}
-
Click on button
Next
-
Enter policy name
ecrPhaProcessorLamdaPolcy
-
Click on
Create policy
-
Come back to your AWS Lambda Function and navigate to
Configuration
tab. -
Go to the
General Configuration
and click onEdit
button. Increase the Timeout to minimum 10 minute. -
Click on
Save
-
Under the "Code" tab select "Upload from"
-
Select .zip or .jar file option.
-
Click upload and navigate to your local workspace target folder and select ecr-pha-processor-lambda-1.0.0.jar and click "Save".
-
Click on "Edit" on "Runtime Settings".
-
Enter below value for Handler
com.drajer.ecr.pha.processor.PHAProcessorLambdaFunctionHandler::handleRequest
- Click "Save"
To process the file from the S3 bucket, lambda function needs to be configured to process from the specified folder. Add the Environment Variable to the lambda function specifying the S3 bucket folder name.
-
Click on "Configuration" tab and then "Environment Variables"
-
Click on "Edit" to add new environment variable
-
Click on "Add new environment variable"
-
Enter
Environment Variable | Value |
---|---|
HTTP_POST_URL | <- HTTP end point reference to eicr responder module -> |
eg: http://<>:<>/eicrresponder/api/receiveeicrrdata
Choose the SQS queue and click Create Queue
-
Select
Standard
and Enter the Name for the Queue aseg: fhir-ecr1-pha-processor-sqs-queue
-
Enter 10 minutes as Visibility timeout
-
Server-Side encryption as
disabled
-
Access Policy
Advanced
-
Make neccessary changes to below and copy as in-line policy
{
"Version": "2012-10-17",
"Id": "__default_policy_ID",
"Statement": [
{
"Sid": "__owner_statement",
"Effect": "Allow",
"Principal": {
"Service": "s3.amazonaws.com"
},
"Action": "SQS:SendMessage",
"Resource": "arn:aws:sqs:us-east-1:<<AWS_ACCOUNT_INFO>>:<<QUEUE_NAME (from the SQS Queue Step 1)>>",
"Condition": {
"StringEquals": {
"aws:SourceAccount": "<<AWS ACCOUNT INFO>>"
},
"ArnLike": {
"aws:SourceArn": "arn:aws:s3:::<<S3 BUCKET NAME>>"
}
}
}
]
}
- Click Save
-
Go to S3 bucket and to Properties Tab
-
Scroll down to
Event Notification
and ClickCreate event Notification
-
Enter Name
eg: rr-fhir-event
-
Enter Suffix as
RR_FHIR.xml
-
Event Types as
All object create events
-
Destination as
SQS queue
-
Specify SQS queue Enter SQS queque
arn:aws:<<SQS NAME (from the SQS Queue Step 1)>>
-
Click
Save Changes
Lambda function needs to be triggered, for this we need to add and configure the trigger. Follow the following steps to add the trigger to your lambda function.
-
Go to you Lambda function
-
Click on
Add trigger
-
From the
Trigger configuration
drop down selectSQS
option -
From the
SQS queque (from the SQS Queue Step 1)
drop down select your SQS that this lambda function will listen. -
Click Add.