kangks

1. Download as zip with command curl -LJO https://gist.github.com/kangks/eda238bdee360070244ff9e53fc71312/archive/7ae513002e69388b438dd2b3e6994b9d2abbb801.zip
2. Extract and run docker-compose up from the folder
3. For first run, wait for the composer to finish download all dependencies
4. Open a browser and enter http://localhost/pinpoint.php as the url

kangks

-- https://docs.cardano.org/projects/plutus/en/latest/tutorials/basic-validators.html#basic-validators-tutorial
-- https://edu.clio.one/lessons/writing-your-first-plutus-smart-contract/lessons/writing-your-first-plutus-code/

module SimpleValidator where

import Data.Text
-- import Language.Plutus.Contract 
import Language.PlutusTx
--import qualified Language.PlutusTx as PlutusTx
import Playground.Contract

kangks

import json
import urllib3

def lambda_handler(event, context):
    return {
        'statusCode': 200,
        'body': get_public_ip()
    }
 
def get_public_ip():

kangks

!pip install --upgrade mxnet-cu$(ls /usr/local/cuda/lib64/libcudart.so.*.? | sed -e 's/.*\.\([0-9]*\.[0-9]*\)/\$1/g' -e 's/\.//g')

kangks

import sys, argparse
import boto3
import pathlib
from pathlib import Path
import random

parser = argparse.ArgumentParser(description='Script to start OTA update')
parser.add_argument("--aws_profile", help="Profile name created using aws configure", default="default", required=False)
parser.add_argument("--s3bucket", help="S3 bucket to store firmware updates", required=True)
parser.add_argument("--s3prefix", help="S3 bucket prefix to store firmware updates", required=False)

kangks

from datetime import datetime
import time
import threading
import json
import logging
import paho.mqtt.client as mqtt
import paho.mqtt.publish as mqtt_publish
import boto3

subscriber_keepalive_sec = 40 * 60 # 40 mins

kangks

kangks

import sys
from awsglue.transforms import *
from awsglue.utils import getResolvedOptions
from pyspark.context import SparkContext
from awsglue.context import GlueContext
from awsglue.job import Job
import json
import requests
from pyspark import sql
from uuid import UUID

kangks

AWSTemplateFormatVersion: '2010-09-09'
Metadata:
  Comment: "Stack for S3 event -> Lambda transform from csv to json -> kinesis stream -> downstream Lambda for each row processing.
  These are the purpose of the demo:
    - Retry of downstream Lambda when failed. The record in Kinesis Stream will not be removed until success Runtime
    - With large CSV, the Lambda will parallel according to number of shards of Kinesis Stream"
Resources:
  IAMRole:
    Type: "AWS::IAM::Role"
    Properties:

kangks

{
  "AWSTemplateFormatVersion": "2010-09-09",
  "Description": "Create AMR Cluster",
  "Parameters": {
    "ProductParam": {
      "Description": "The EMR Product tag",
      "Type": "String",
      "Default": "aProductParam",
      "MinLength": "3",
      "MaxLength": "50",