Skip to content

Instantly share code, notes, and snippets.

View Udith's full-sized avatar

Udith Gunaratna Udith

View GitHub Profile
image: nikolaik/python-nodejs:python3.8-nodejs14
pipelines:
branches:
master:
- step:
# Builds project
name: Build Project
script:
- npm i slappforge-sigma-cli -g
name: Auto Deployment
on:
push:
branches: [ main ]
paths-ignore:
- '.github/**'
jobs:
deployment:
const AWS = require('aws-sdk');
const s3 = new AWS.S3();
let mime = require('mime-types')
exports.handler = async (event) => {
console.log("Request received");
// Extract file content
let fileContent = event.isBase64Encoded ? Buffer.from(event.body, 'base64') : event.body;
{
"resource": "/{proxy+}",
"path": "/hello/world",
"httpMethod": "POST",
"headers": {
"Accept": "*/*",
"Accept-Encoding": "gzip, deflate",
"cache-control": "no-cache",
},
"multiValueHeaders":{
Service Maximum Message Size Maximum Throughput Retention Period Guaranteed Ordering Every subscriber can receive each message
SQS Standard 256KB Unlimited Default 4 days. Can be configured to a value between 60s and 14 days
SQS FIFO 256KB 3000/s Default 4 days. Can be configured to a value between 60s and 14 days
SNS 256KB Unlimited Default 4 weeks. A TTL can be set up to 14 days
Kinesis 1MB 1000/s per shard Default 24 hours. Can be increased up to 7 days
DDB Streams 400KB 40000/s or 10000/s based on region 24 hours
Azure Queue Storage 64KB 2000/s Infinite
let AWS = require('aws-sdk');
const sns = new AWS.SNS();
exports.handler = async (event) => {
let receiver = event['receiver'];
let sender = event['sender'];
let message = event['message'];
let isPromotional = true;
exports.handler = async (event) => {
let receiver = event['receiver'];
let sender = event['sender'];
let message = event['message'];
let isPromotional = true;
console.log("Sending message", message, "to receiver", receiver);
let AWS = require('aws-sdk');
const sns = new AWS.SNS();
const s3 = new AWS.S3();
exports.handler = function (event, context, callback) {
console.log(`Batch process triggered at ${event.time}`);
s3.listObjects({
'Bucket': 'batch-process-bucket-udith',
'MaxKeys': 100,
/*
This function publishes the provided message with subject to the notification
topic and excute the provided onSuccess or onFailure callback handler
*/
exports.sendNotification = (subject, message, onSuccess, onFailure) => {
sns.publish({
Message: message,
Subject: subject,
MessageAttributes: {},
MessageStructure: 'String',
let AWS = require('aws-sdk');
const s3 = new AWS.S3();
exports.handler = function (event, context, callback) {
console.log(`Batch process triggered at ${event.time}`);
s3.listObjects({
'Bucket': 'batch-process-bucket-udith',
'MaxKeys': 100,
'Prefix': ''