Fixed order of data that's being streamed in

README.md

@@ -13,15 +13,14 @@ This demo application consists of the following components:
 
 ## High-Level Architecture
 
-![Image of High-Level Architecture](blog_stock_dashboard.png)
+![Image of High-Level Architecture](doc-images/blog_stock_dashboard.png)
 
 # Local Installation
 
 ## Install the [AWS Amplify Framework CLI](https://aws-amplify.github.io/docs/)
 
 ```bash
 npm install -g @aws-amplify/cli
-amplify configure
 ```
 
 ## Clone the repo from [Github](https://github.com/jmgtan/stock_dashboard)
@@ -108,4 +107,33 @@ Update the following values:
 * `cognito_backend_access_key`: value is `stockMonitoring/<env>/backend`
 * `appsync_endpoint_url`: use the value from the file `src/aws-exports.js` in the `aws_appsync_graphqlEndpoint` variable
 * `appsync_region`: use the value from the file `src/aws-exports.js` in the `aws_appsync_region` variable
-* `data_feed_key`: value is `stockMonitoring/<env>/datafeed`
+* `data_feed_key`: value is `stockMonitoring/<env>/datafeed`
+
+## Deploy via CloudFormation
+
+Create S3 bucket to serve as the staging area for deploying the Lambda function. This will be used by the AWS CloudFormation package command.
+
+```bash
+aws s3api create-bucket --bucket <staging bucket name> --create-bucket-configuration LocationConstraint=eu-west-1
+```
+
+Next we package and stage the Lambda function
+
+```bash
+cd processors
+aws cloudformation package --template-file cf-template.yaml --s3-bucket <staging bucket name> --output-template-file packaged-template.yaml
+```
+
+Once the command succeeds you can then execute the deploy command
+
+```bash
+aws cloudformation deploy --template-file packaged-template.yaml --stack-name <stack name> --capabilities CAPABILITY_IAM
+```
+
+Once deployment completes, going to the CloudFormation console and into the stack, you should be able to see the list of resources that were created
+
+![List of CloudFormation Resources](doc-images/cf-resources.png)
+
+Clicking the Lambda function, you should be able to see the trigger, which is a CloudWatch scheduled event for every 30 mins.
+
+![Lambda Trigger](doc-images/lambda-trigger.png)

processors/GetIntradayPrices/index.js

@@ -74,7 +74,7 @@ const getPrices = async(apiKey, symbol) => {
             });
         }
 
-        return prices;
+        return prices.reverse();
     }
 }
 
@@ -89,7 +89,7 @@ const writePrices = async(client, prices) => {
     }
 }
 
-const test = async() => {
+exports.handler = async(event) => {
     const sm = new AWS.SecretsManager();
     const backendTokens = await getBackendTokens(sm);
     const client = buildAppSyncClient(backendTokens);
@@ -120,6 +120,4 @@ const test = async() => {
             }
         }
     } while (nextToken != null);
-}
-
-test();
+}

processors/GetIntradayPrices/package.json

@@ -10,6 +10,7 @@
     "aws-sdk": "^2.512.0",
     "axios": "^0.19.0",
     "graphql-tag": "^2.10.1",
-    "isomorphic-fetch": "^2.2.1"
+    "isomorphic-fetch": "^2.2.1",
+    "moment-timezone": "^0.5.26"
   }
 }

processors/cf-template.yaml

@@ -0,0 +1,27 @@
+AWSTemplateFormatVersion: "2010-09-09"
+Transform: AWS::Serverless-2016-10-31
+Resources:
+  GetIntradayPricesFunction:
+    Type: AWS::Serverless::Function
+    Properties:
+      Handler: index.handler
+      CodeUri: GetIntradayPrices/
+      Runtime: nodejs10.x
+      MemorySize: 256
+      Timeout: 120
+      Policies:
+        - AWSLambdaExecute
+        - Version: '2012-10-17'
+          Statement:
+            - Effect: 'Allow'
+              Action:
+                - secretsmanager:GetSecretValue
+                - cognito-idp:AdminInitiateAuth
+              Resource: '*'
+      Events:
+        ScheduledExec:
+          Type: Schedule
+          Properties:
+            Schedule: rate(30 minutes)
+            Name: GetIntradayPricesSchedule
+            Enabled: true

processors/packaged-template.yaml

@@ -0,0 +1,27 @@
+AWSTemplateFormatVersion: '2010-09-09'
+Transform: AWS::Serverless-2016-10-31
+Resources:
+  GetIntradayPricesFunction:
+    Type: AWS::Serverless::Function
+    Properties:
+      Handler: index.handler
+      CodeUri: s3://jmgtan-local-stock-dash/a8249a09aa05066b1adddd840b3e9b4e
+      Runtime: nodejs10.x
+      MemorySize: 256
+      Timeout: 120
+      Policies:
+      - AWSLambdaExecute
+      - Version: '2012-10-17'
+        Statement:
+        - Effect: Allow
+          Action:
+          - secretsmanager:GetSecretValue
+          - cognito-idp:AdminInitiateAuth
+          Resource: '*'
+      Events:
+        ScheduledExec:
+          Type: Schedule
+          Properties:
+            Schedule: rate(30 minutes)
+            Name: GetIntradayPricesSchedule
+            Enabled: true