rate limiting

README.md

@@ -16,3 +16,7 @@
 
 [Coin Price List](./coin-price-list/): Backendless GraphQL use case with Next.js and Redis.
 
+[Serverless Histogram API](./histogram-api/): Histogram API with AWS Lambda and Redis.
+
+[Redisson](./redisson/): Example code that uses Redisson as client.
+

bull/index.js

@@ -0,0 +1,15 @@
+var Queue = require('bull');
+
+var videoQueue = new Queue('video transcoding', 'REPLACE_REDIS_URL_HERE')
+// var videoQueue = new Queue('video transcoding', 'redis://127.0.0.1:6379');
+
+
+videoQueue.process(function(job, done){
+    console.log(job.data)
+    done();
+}).catch(err => {
+    console.log(err)
+});
+
+
+videoQueue.add({video: 'http://example.com/video1.mov'});

serverless-rate-limiting/.npmignore

@@ -0,0 +1,6 @@
+# package directories
+node_modules
+jspm_packages
+
+# Serverless directories
+.serverless

serverless-rate-limiting/handler.js

@@ -0,0 +1,35 @@
+const RateLimiter = require('async-ratelimiter')
+const Redis = require('ioredis')
+const { getClientIp } = require('request-ip')
+
+const rateLimiter = new RateLimiter({
+    db: new Redis("rediss://:ec0651dac90948de97cf09a57a74fd62@usw1-selected-termite-30690.upstash.io:30690"),
+    max: 1,
+    duration: 5_000
+})
+
+module.exports.hello = async (event) => {
+    const clientIp = getClientIp(event) || 'NA'
+    const limit = await rateLimiter.get({id: clientIp})
+    if (!limit.remaining) {
+        return {
+            statusCode: 429,
+            body: JSON.stringify(
+                {
+                    message: 'Sorry, you are rate limited. Wait for 5 seconds',
+                    client: clientIp
+                },
+            ),
+        };
+    }
+
+    return {
+        statusCode: 200,
+        body: JSON.stringify(
+            {
+                message: 'hello!',
+                client: clientIp
+            },
+        ),
+    };
+};

serverless-rate-limiting/package.json

@@ -0,0 +1,7 @@
+{
+  "dependencies": {
+    "async-ratelimiter": "^1.2.8",
+    "ioredis": "^4.27.1",
+    "request-ip": "^2.1.3"
+  }
+}

serverless-rate-limiting/serverless.yml

@@ -0,0 +1,14 @@
+service: serverless-rate-limiting
+frameworkVersion: '2'
+provider:
+  name: aws
+  runtime: nodejs12.x
+  lambdaHashingVersion: 20201221
+  region: us-west-1
+functions:
+  hello:
+    handler: handler.hello
+    events:
+      - httpApi:
+          path: /hello
+          method: get