Skip to content

Instantly share code, notes, and snippets.

View alessandrobologna's full-sized avatar

Alessandro Bologna alessandrobologna

View GitHub Profile
/*
* Just consume events from Kinesis in a sink
*/
const pause = parseInt(process.env.PAUSE_TIME || '0');
//const pause = 0;
const sleep = (ms) => {
return new Promise(resolve => setTimeout(resolve, ms));
};
[
{
"kinesis": {
"approximateArrivalTimestamp": 1521218148.073,
"kinesisSchemaVersion": "1.0",
"partitionKey": "a1627837-a899-4dab-851e-98530ce557aa",
"sequenceNumber": "49582644240588213996014774893955628290209495172536860674",
"data": {
"MessageType": "Claps",
"EntitySequenceId": "0",
[
{
"kinesis": {
"approximateArrivalTimestamp": 1521218149.056,
"kinesisSchemaVersion": "1.0",
"partitionKey": "post-4897249772",
"sequenceNumber": "49582644240588213996014774893954419364389880543362154498",
"data": {
"MessageType": "Claps",
"EntityId": "claps-32142459-4897249772",
@alessandrobologna
alessandrobologna / kinesis.0.json
Last active March 23, 2018 15:42
kinesis.0.json
[
{
"kinesis": {
"approximateArrivalTimestamp": 1521218148.073,
"kinesisSchemaVersion": "1.0",
"partitionKey": "claps-32142459-4897249772",
"sequenceNumber": "49582644240588213996014774893955628290209495172536860674",
"data": {
"MessageType": "Claps",
"EntityId": "claps-32142459-4897249772",
@alessandrobologna
alessandrobologna / kinesis.2.json
Last active March 19, 2018 01:02
kinesis sample 1
[
{
"kinesis": {
"approximateArrivalTimestamp": 1521218148.073,
"kinesisSchemaVersion": "1.0",
"partitionKey": "a1627837-a899-4dab-851e-98530ce557aa",
"sequenceNumber": "49582644240588213996014774893955628290209495172536860674",
"data": {
"MessageType": "Claps",
"Id": "1",
{
"Id" : "3187949234",
"ClappeId" : "32142459",
"PostId" : "4897249772",
"Claps" : "21"
}
#!/bin/bash
if [ "$1" = "run" ]
then
RUN_FLAGS=""
case $STAGE in
dev)
# set flags for dev enviroment
RUN_FLAGS="-Dspring.profiles.active=dev -Dcom.example.mock=local"
;;
qa)
apiVersion: v1
kind: Service
metadata:
name: {{APPNAME}}
namespace: {{NAMESPACE}}
annotations:
service.beta.kubernetes.io/aws-load-balancer-external: 0.0.0.0/0
service.beta.kubernetes.io/aws-load-balancer-backend-protocol: http
service.beta.kubernetes.io/aws-load-balancer-ssl-cert: {{CERTIFICATE_ARN}}
dns.alpha.kubernetes.io/internal: "{{APPNAME}}.{{NAMESPACE}}.{{CLUSTER}}"
apiVersion: extensions/v1beta1
kind: Deployment
metadata:
name: {{APPNAME}}
namespace: {{NAMESPACE}}
spec:
replicas: 3
template:
metadata:
labels:
@alessandrobologna
alessandrobologna / infra.yaml
Last active February 24, 2018 22:36
Minimal Kubernetes Deployment
apiVersion: extensions/v1beta1
kind: Deployment
metadata:
name: {{APPNAME}}
namespace: {{NAMESPACE}}
spec:
replicas: 3
template:
metadata:
labels: