bdnf

from pyspark.sql.functions import *


spark = (SparkSession
 .builder
 .appName("PythonMnMCount")
 .getOrCreate())
lines = (spark
  .readStream.format("socket")
  .option("host", "localhost")

bdnf

import org.apache.spark.sql.functions._
import org.apache.spark.sql.streaming._


val spark = SparkSession
  .builder
  .appName("MnMCount")
  .getOrCreate()
val lines = spark
  .readStream.format("socket")

bdnf

Fetch configuration from SSM parameter store:
# /opt/aws/amazon-cloudwatch-agent/bin/amazon-cloudwatch-agent-ctl -a fetch-config -m ec2 -c ssm:configuration-parameter-store-name -s

Fetch config from local path:
/opt/aws/amazon-cloudwatch-agent/bin/amazon-cloudwatch-agent-ctl -a fetch-config -m onPremise -s -c /etc/cwagentconfig/metrics.json

For check the status, run:
/opt/aws/amazon-cloudwatch-agent/bin/amazon-cloudwatch-agent-ctl -m ec2 -a status

bdnf

#! /bin/sh
yum update -y
amazon-linux-extras install docker
service docker start
usermod -a -G docker ec2-user
chkconfig docker on

sudo curl -L https://github.com/docker/compose/releases/latest/download/docker-compose-$(uname -s)-$(uname -m) -o /usr/local/bin/docker-compose

sudo chmod +x /usr/local/bin/docker-compose

bdnf

import requests
import random
import sys
import argparse

def getClicked(rate):
	if random.random() <= rate:
		return True
	else:
		return False

bdnf

#!/bin/sh
while true
do
  deviceID=$(( ( RANDOM % 10 )  + 1 ))
  heartRate=$(jot -r 1 60 140)
  echo "$deviceID,$heartRate"
  aws kinesis put-record --stream-name <your_stream_name> --data "$deviceID,$heartRate"$'\n' --partition-key $deviceID --region us-east-1
done

bdnf

class Pants:
    """The Pants class represents an article of clothing sold in a store
    """

    def __init__(self, color, waist_size, length, price):
        """Method for initializing a Pants object

        Args: 
            color (str)
            waist_size (int)

bdnf

[package]
name = "graph"
version = "0.1.0"
authors = ["me"]
edition = "2020"

[lib]
name = "service"
path = "src/lib.rs"

bdnf

import datetime
import logging

from airflow import DAG
from airflow.models import Variable
from airflow.operators.python_operator import PythonOperator
from airflow.hooks.S3_hook import S3Hook


def list_keys():

bdnf

const AWS = require('aws-sdk')
const axios = require('axios')

// Name of a service, any string
const serviceName = process.env.SERVICE_NAME

// URL of a service to test
const url = process.env.URL

// CloudWatch client