vvalorous

One of 2016's key buzzwords was serverless - but is anyone sure what that means? Both AWS Lambda and Kubernetes Jobs provide their own solutions in this space, but..

I'm not sure that we have a clearly defined standard on what serverless should look like and how it should behave.

Here are some of my thoughts on serverless based upon what I've seen this year:

• tends involve invoking short-lived functions (Lambda has a default 1-sec timeout)
• does not publish TCP services - often accesses third-party services or resources
• tends to be ad-hoc/event-driven such as responding to webhooks
• should deal gracefully with spikes in traffic

vvalorous

var https = require('https');
var util = require('util');
var webhook = '/services/webhook';
var errorMessage = "ERROR";

exports.handler = function(event, context) {
    console.log(JSON.stringify(event, null, 2));
    console.log('From SNS:', event.Records[0].Sns.Message);

    var postData = {

vvalorous

#!/usr/bin/env python
import boto3
import json

sns = boto3.client("sns")
topic_arn = "YOUR_SNS_TOPIC"
proto = "http"
endpoint = "YOUR_EDNPOINT"
attributes = {"FilterPolicy": json.dumps({"key": ["foo", "bar"]})} 

vvalorous

#!/usr/bin/python2.7
# https://gist.github.com/daniel-woods

import json
from urllib2 import urlopen, HTTPError, Request


def post_message(url, data):
    req = Request(url, data)
    f = urlopen(req)

vvalorous

#!/usr/bin/python3
# https://gist.github.com/daniel-woods
# Use a Webhook to send a message to a Microsoft Teams channel using Connectors/Incoming Webhook

import json
from urllib2 import urlopen, HTTPError, Request


def post_message(url, data):
    req = Request(url, data)

vvalorous

var https = require('https');
var util = require('util');

exports.handler = function (event, context) {
    console.log(JSON.stringify(event, null, 2));
    console.log('From SNS:', event.Records[0].Sns.Message);

    var severity = "good";
    var message = event.Records[0].Sns.Message;
    var messageJSON = JSON.parse(message);

vvalorous

from flask import Flask, request
import requests
import json

app = Flask(__name__)

def msg_process(msg, tstamp):
    js = json.loads(msg)
    msg = 'Region: {0} / Alarm: {1}'.format(
        js['Region'], js['AlarmName']

vvalorous

var https = require('https');
var util = require('util');

exports.handler = function(event, context) {
    console.log(JSON.stringify(event, null, 2));
    console.log('From SNS:', event.Records[0].Sns.Message);

    var postData = {
        "channel": "#aws-sns",
        "username": "AWS SNS via Lamda :: DevQa Cloud",

vvalorous

var https = require('https');
var util = require('util');
var webhook = '/services/T00000000/B00000000/XXXXXXXXXXXXXXXXXXXXXXXX';

exports.handler = function(event, context) {
    console.log(JSON.stringify(event, null, 2));
    console.log('From SNS:', event.Records[0].Sns.Message);

    var postData = {
        "text": "*" + event.Records[0].Sns.Subject + "*"

vvalorous

# Lambda function to subscribe all new cloudwatch log groups to a log shipper function
# Used in conjunction with https://github.com/SumoLogic/sumologic-aws-lambda
import os
import logging
import json
import uuid

import boto3
from botocore.exceptions import ClientError