RDIoT Demo

3D Printed ikea skadis pegboard accessories

* Reference Source

- https://www.thingiverse.com/thing:2849398

- https://www.thingiverse.com/thing:2849369

- https://www.thingiverse.com/thing:2853257

- https://www.thingiverse.com/thing:2851040

- https://www.thingiverse.com/thing:2933140

- https://www.thingiverse.com/thing:4042873

- https://www.thingiverse.com/thing:4196820

- https://www.thingiverse.com/thing:4115425

- https://www.thingiverse.com/thing:2791919

- https://www.thingiverse.com/thing:2749146

- https://www.thingiverse.com/thing:2773037

- https://www.thingiverse.com/thing:2347090

- https://www.thingiverse.com/thing:2648038

- https://www.thingiverse.com/thing:3392612

- https://www.thingiverse.com/thing:3181792

- https://www.thingiverse.com/thing:4247453

- https://www.thingiverse.com/thing:2665067

- https://www.thingiverse.com/thing:3772318

DynamoDB Stream + Amazon ES (ElasticSearch, Kibana) [P024]

* Parts

- Raspberry Pi 

- AWS Lambda Java Project in Ecplise

* Contents

1. Upload sensor data to json file using the Amazon S3 Rest API

- Pi4J + Amazon S3 REST API + Amazon Athena [P019]

2. Amazon Lambda S3 Trigger (node.js) : S3toDynamoDB

- source code : https://github.com/rdiot/rdiot-p022/blob/master/S3toDynamoDB/index.js

'use strict';

console.log('RDIoT S3toDynamoDB Loading post function');

var AWS = require('aws-sdk'); 

var s3 = new AWS.S3();

var dynamo = new AWS.DynamoDB.DocumentClient();

exports.handler = function(event, context, callback) {

    console.log('Received event:', JSON.stringify(event, null, 2));

    var bucket = event.Records[0]['s3']['bucket']['name'];

    var en = event.Records[0]['eventName'];

    var et = event.Records[0]['eventTime'];

    var key = event.Records[0]['s3']['object']['key'];

    var sip = event.Records[0]['requestParameters']['sourceIPAddress'];

    var params1 = {Bucket: bucket, Key: key}; 

    s3.getObject( params1, function(err,data) {

        if(err) {

            console.log(err.stack);

            callback(err);

        } else {

            var value = data.Body.toString('ascii')

            console.log(data);

            console.log("Raw text:\n" + value);

            var params2 = {

                TableName: "pi-sensor",

                Item:{

                    "id": et,

                    "event" : en,

                    "bucket": bucket,

                    "key" : key,

                    "sip": sip,

                    "value" : value

                }

            };

            console.log("Gettings IoT device details...");

            //S3 to DynamoDB

            dynamo.put(params2, function(err, data) {

                if(err) {

                    console.error("Unable to post devices. Error JSON:", JSON.stringify(err, null, 2));

                    context.fail();

                } else {

                    console.log("keepet data:", JSON.stringify(data, null, 2));

                    context.succeed('success post');

                }

            });

        }

    });

}

3. AWS DynamoDB Monitoring

4. Create IAM Role

- It must have basic Amazon ES, DynamoDB, and Lambda execution permissions

- create custom role name : LambdaDynamoDBtoES

{

  "Version": "2012-10-17",

  "Statement": [

    {

      "Effect": "Allow",

      "Action": [

        "es:ESHttpPost",

        "es:ESHttpPut",

        "dynamodb:DescribeStream",

        "dynamodb:GetRecords",

        "dynamodb:GetShardIterator",

        "dynamodb:ListStreams",

        "logs:CreateLogGroup",

        "logs:CreateLogStream",

        "logs:PutLogEvents"

      ],

      "Resource": "*"

    }

  ]

}

5. Setup Amazon ES (Elasticsearch + Kibana)

- Define domain

- Configure cluster

- Set up access

- Review

- Service dashboard

6. Amazon Lambda DynamoDB Stream Trigger (java) : DynamoDBtoES

https://docs.amazonaws.cn/en_us/elasticsearch-service/latest/developerguide/es-aws-integrations.html#es-aws-integrations-dynamodb-es

https://docs.aws.amazon.com/ko_kr/elasticsearch-service/latest/developerguide/aes-dg.pdf

Bluetooth Audio Receiver Board [B210]

https://www.youtube.com/watch?v=k3NmiGb3d9E

* Specs

Audio input mode:Bluetooth receiver

USB decode and play

TF card decoding playback

Support Playback Format: MP3，WMA，WAV，FLAC

Power Supply: DC 5V (original phone charger can power small USB plug)

Board Size：50 x 40mm

Preamp output can be directly promote the headset and also can be followed

by the use of the power amp

* Contents

- Connect 

- Sample

Infrared distance sensor (GP2Y0A21YK0F) [S036]

https://www.youtube.com/watch?v=GhNwmtpVTY4

*GitHub : https://github.com/rdiot/rdiot-s036.git

* Specs

operating voltage: 4.5 V to 5.5 V

average current consumption: 30 mA (typical)

distance measuring range: 10 cm to 80 cm (4" to 32")

output type: analog voltage

output voltage differential over distance range: 1.9 V (typical)

response time: 38 ± 10 ms

package size: 29.5×13.0×13.5 mm (1.16×0.5×0.53")

weight: 3.5 g (0.12 oz)

* Contents

- DataSheet : http://www.sparkfun.com/datasheets/Components/GP2Y0A21YK.pdf

- Connect 

Yellow ----- A0

Black ----- GND

Red ----- 5V

- Key Code

int pin = A0;

int I = analogRead(pin);

int value = (6762 /(I-9)) -(4);

lcd.print("distance=" + (String)value + "CM  ");

Serial MP3 Music Player Module for Arduino (YX5300) [B208]

https://www.youtube.com/watch?v=D9rsBf1b3CM

GitHub : https://github.com/rdiot/rdiot-b208

* Specs

The module is a kind of simple MP3 player device which is based on a high-quality MP3 audio chip---YX5300. It can support 8k Hz ~ 48k Hz sampling frequency MP3 and WAV file formats.

There is a TF card socket on board, so you can plug the micro SD card that stores audio files. MCU can control the MP3 playback state by sending commands to the module via UART port, such as

switch songs, change the volume and play mode and so on. You can also debug the module via USB

to UART module. It is compatible with Arduino / AVR / ARM / PIC.

Features：

1. Support sampling frequency (kHz): 8 / 11.025 / 12 / 16 / 22.05 / 24 / 32 / 44.1 / 48

2. High quality

3. Support file format: MP3 / WAV

4. Support Micro SD card, Micro SDHC Card

5. 30 class adjustable volume

6. UART TTL serial control playback mode, baud rate is 9600bps

7. Power supply can be 3.2 ~ 5.2VDC

8. Control logic interface can be 3.3V / 5V TTL

9. Compatible with Arduino UNO / Leonardo / Mega2560 / DUE

* Contents

- interface 

- Connect 

Serial MP3 Player - Arduino

GND - GND

VCC - 5V

TX - D5

RX - D6

- Commonly Command bytes Descriptions

- tested source code 

 : https://github.com/rdiot/rdiot-b208/blob/master/SerialMp3PlayerControl.ino.ino

- Key Code

#include <SoftwareSerial.h>

#define ARDUINO_RX 5 // TX - Arduino RX

#define ARDUINO_TX 6 // RX - Arduino TX

SoftwareSerial mySerial(ARDUINO_RX, ARDUINO_TX);

unsigned char playmode = 1; 

  #define PLAY  1

  #define PAUSE 0

static int8_t Send_buf[8] = {0} ;

/************Command byte**************************/

#define CMD_NEXT_SONG 0X01

#define CMD_PREV_SONG 0X02

#define CMD_PLAY_W_INDEX 0X03

#define CMD_VOLUME_UP 0X04

#define CMD_VOLUME_DOWN 0X05

#define CMD_SET_VOLUME 0X06

#define CMD_SINGLE_CYCLE_PLAY 0X08

#define CMD_SEL_DEV 0X09

#define DEV_TF 0X02

#define CMD_SLEEP_MODE 0X0A

#define CMD_WAKE_UP 0X0B

#define CMD_RESET 0X0C

#define CMD_PLAY 0X0D

#define CMD_PAUSE 0X0E

#define CMD_PLAY_FOLDER_FILE 0X0F

#define CMD_STOP_PLAY 0X16

#define CMD_FOLDER_CYCLE 0X17

#define CMD_SET_SINGLE_CYCLE 0X19

#define SINGLE_CYCLE_ON 0X00

#define SINGLE_CYCLE_OFF 0X01

#define CMD_SET_DAC 0X1A

#define DAC_ON  0X00

#define DAC_OFF 0X01

#define CMD_PLAY_W_VOL 0X22

/*********************************************************************/

#define ROTARY_ANGLE_SENSOR A0

#define ADC_REF 5//reference voltage of ADC is 5v

#define VCC     5    //the default value of VCC of the control interface is 5v

#define FULL_ANGLE 280//full value of the rotary angle is 280 degrees

void setup() 

{

  //pinMode(2, INPUT); // Button - Paluse&Play

  Serial.begin(9600);

  mySerial.begin(9600);

  delay(500);

  attachInterrupt(0, playOrPause, RISING);//pin2 -> INT0, and the Touch Sensor 

                                          //is connected with pin2 of Arduino

  sendCommand(CMD_SEL_DEV, DEV_TF);    

  delay(200);

  sendCommand(CMD_PLAY_W_VOL, 0X0F01);

}

static int8_t pre_vol = 0x0f; 

void loop() 

{

  int degrees;

  degrees = getDegree();

  int8_t volume;

  /*The degrees is 0~280, should be converted to be 0~255 to control the*/

  /*brightness of LED */

  volume = map(degrees, 0, 280, 30, 0); 

  if(volume != pre_vol)

  {

    sendCommand(CMD_SET_VOLUME, volume);

    pre_vol = volume;

  }

  delay(100);

}

void sendCommand(int8_t command, int16_t dat)

{

  delay(20);

  Send_buf[0] = 0x7e; //

  Send_buf[1] = 0xff; //

  Send_buf[2] = 0x06; //

  Send_buf[3] = command; //

  Send_buf[4] = 0x00;//

  Send_buf[5] = (int8_t)(dat >> 8);//datah

  Send_buf[6] = (int8_t)(dat); //datal

  Send_buf[7] = 0xef; //

  for(uint8_t i=0; i<8; i++)//

  {

    mySerial.write(Send_buf[i]);  

  }

}

int getDegree()

{

  int sensor_value = analogRead(ROTARY_ANGLE_SENSOR);

  float voltage;

  voltage = (float)sensor_value*ADC_REF/1023;

  float degrees = (voltage*FULL_ANGLE)/VCC;

  return degrees;

}

/*Interrupt service routine*/

void playOrPause()

{

  cli();

  if(playmode == PLAY)

  {

    playmode = PAUSE;

  sendCommand(CMD_PAUSE,0);

  }

  else

  {

    playmode = PLAY;

  sendCommand(CMD_PLAY,0);

  }

  sei();

}

- Reference

CATALEX Serial MP3 Player manual version v1.0.1

 : https://github.com/rdiot/rdiot-b208/blob/master/Serial%20MP3%20Player%20v1.0%20Manual.pdf

Serial Debug tool - SSCOM32 

 : https://github.com/rdiot/rdiot-b208/blob/master/Serial%20Debug%20tool%20-%20SSCOM32.zip

Serial MP3 Player Demo Code 

 : https://github.com/rdiot/rdiot-b208/blob/master/SerialMP3PlayerDemoCode%20for%20Arduino-1.0.zip

LW-101 LED Display Water Temperature Meter Monitor [B209]

https://www.youtube.com/watch?v=1FiPwYkkRFg

* Specs

Features: 

No batteries required - The device harvests its energy from the water flow Quick and easy installation without any tools - fits with handheld showerhead Materials approved for drinking water 

Newest innovated technology to upgrade and modernize your bath room;

self powered battery free thermometer to monitor your shower temperature.

As home essential Needed - to serve and surprise your husband, wife or kids.

(Especially for families having toddlers or babies)

High-precision temperature sensor 360°rotatable waterproof led screen for better viewing.

Specification:  

Material : ABS, PC

Size : connect to standard 1/2inch hose or shower head;

Temperate Range : 32-212 ℉, 0-100℃

Weight : 80g

* Contents

- Connect 

S3 Lambda Trigger + Amazon SQS + SQSReceiver + SparkStreaming [P023]

https://www.youtube.com/watch?v=37gl-tkUa3M

GitHub : https://github.com/rdiot/rdiot-p023

* Parts

- Pi4J + Amazon S3 REST API + Amazon Athena [P019]

- Raspberry Pi2

- Temperature and humidity DHT11 sensor module (KY-015) [S008]

* Contents

1. Create custom role : AWS Lambda required acess to your resources

- Create a new IAM Role

- Role Name : LambdaSQSRole

- Attach policy : AmazonSQSFullAccess 

- SQS Receiver : https://github.com/rdiot/rdiot-p023/blob/master/sparkReceiver/src/main/java/com/rdiot/sparkReceiver/receiver/SQSReceiver.java

- SQS Receiver with Delete : https://github.com/rdiot/rdiot-p023/blob/master/sparkReceiver/src/main/java/com/rdiot/sparkReceiver/SQSWithDelete.java

- SQS Receiver without Delete : https://github.com/rdiot/rdiot-p023/blob/master/sparkReceiver/src/main/java/com/rdiot/sparkReceiver/SQSWithoutDelete.java

- s3 event word count source : https://github.com/rdiot/rdiot-p023/blob/master/sparkReceiver/src/main/java/com/rdiot/sparkReceiver/sample/SQSWordCount.java

package com.rdiot.sparkReceiver.sample;

import java.util.Arrays;

import org.apache.log4j.Level;

import org.apache.log4j.Logger;

import org.apache.spark.SparkConf;

import org.apache.spark.streaming.Duration;

import org.apache.spark.streaming.Durations;

import org.apache.spark.streaming.api.java.JavaDStream;

import org.apache.spark.streaming.api.java.JavaPairDStream;

import org.apache.spark.streaming.api.java.JavaReceiverInputDStream;

import org.apache.spark.streaming.api.java.JavaStreamingContext;

import com.amazonaws.regions.Regions;

import com.rdiot.sparkReceiver.SQSWithoutDelete;

import com.rdiot.sparkReceiver.receiver.SQSReceiver;

import scala.Tuple2;

public class SQSWordCount {

  private static Logger logger = Logger.getLogger(SQSWithoutDelete.class);

    final static String appName = "sparkSQSReceiver";

    final static String master = "local[2]";

    final static String queueName = "jobQueue";

    final static Duration batchDuration = Durations.seconds(5); // Batch Duration 

    final static Duration windowDuration = Durations.seconds(5); // TBD

    final static Duration slideDuration = Durations.seconds(3); // TBD

public static void main(String[] args) throws InterruptedException {

    Logger.getLogger("org").setLevel(Level.OFF);

    //Spark Config 

        SparkConf conf = new SparkConf().setMaster(master).setAppName(appName);

        conf.set("spark.testing.memory", "2147480000");  // if you face any memory issues

try (JavaStreamingContext jssc = new JavaStreamingContext(conf, batchDuration)) {

SQSReceiver javaSQSReceiver = new SQSReceiver(queueName) // 메시지큐 즉시 삭제 

.with(Regions.AP_NORTHEAST_2);

        System.out.println("# Spark Streaming Start");

JavaReceiverInputDStream<String> input = jssc.receiverStream(javaSQSReceiver);

// SQS Messages

/*

        input.foreachRDD(rdd->{

            rdd.foreach(w->{

            System.out.println(w);

            });

        });

        */

        // Word Count

        JavaDStream<String> words = input.flatMap(x -> Arrays.asList(x.split(" ")).iterator());

        JavaPairDStream<String, Integer> pairs = words.mapToPair(s -> new Tuple2<>(s, 1));

        JavaPairDStream<String, Integer> wordCounts = pairs.reduceByKey((i1, i2) -> i1 + i2);        

        wordCounts.print();

jssc.start();

jssc.awaitTermination();

} finally {

logger.info("Exiting the Application");

}

}

}

7. Result

- SQS Message

- Word Count : split ':'

* Reference

- AWS Lambda Permissions Model : https://docs.aws.amazon.com/lambda/latest/dg/intro-permission-model.html

- AWS SQS JS : https://docs.aws.amazon.com/AWSJavaScriptSDK/latest/AWS/SQS.html

- Spark Streaming Custom Receiver : http://spark.apache.org/docs/latest/streaming-custom-receivers.html

TDA7492P Bluetooth 4.0 Amplifier Board 8-25V 50W (TDA7492P) [D091]

https://www.youtube.com/watch?v=bO7p7wcF7wA

* Specs

- Description

TDA7492P digital amplifier chip, designed to optimize the circuit layout, the sound quality is very good, with big power. 

DIP switches can be more easily direcly adjusted after-class amplifier gain, to better promote the impedance larger speakers. 

- Specs

Net weight: approx. 33g 

Product size: approx.80*50*15mm/3.14*1.96*0.59'' 

Power: 2.1 interface DC 8~25V power supply 

Audio input: stereo input various versions of the Bluetooth connection, using CSP8635 Bluetooth chip, Bluetooth V4.0, high software compatibility. 

Output Impedance: 8 ohms Best(4,6,8,16 ohm impedance can drive speakers) 

Output power: Add pre-5532 output foot(powered 25V, 6-ohm impedance output 2 X 50W, 8ohm impedance output 2 X 40W dual-channel) 

Pi4J + Amazon S3 REST API + S3 Lambda Trigger + DynamoDB [P022]

https://www.youtube.com/watch?v=LHZBQmybbqc

GitHub : https://github.com/rdiot/rdiot-p022

* Parts

- Pi4J + Amazon S3 REST API + Amazon Athena [P019]

- Raspberry Pi2

- Temperature and humidity DHT11 sensor module (KY-015) [S008]

* Contents

1. S3 Upload 

- Reference : Pi4J + Amazon S3 REST API + Amazon Athena [P019]

2. Run Java Application (pi4j)

- Source : 

$ java -Dpi4j.linking=dynamic -jar pi4j_s3rest-0.0.1-SNAPSHOT.jar

3.  S3 Storage Monitoring

4. AWS Lambda Monitoring

5. AWS DynamoDB Monitoring

6. AWS Lambda Source (node.js) : S3toDynamoDB

- source code : https://github.com/rdiot/rdiot-p022/blob/master/S3toDynamoDB/index.js

'use strict';

console.log('RDIoT S3toDynamoDB Loading post function');

var AWS = require('aws-sdk'); 

var s3 = new AWS.S3();

var dynamo = new AWS.DynamoDB.DocumentClient();

exports.handler = function(event, context, callback) {

    console.log('Received event:', JSON.stringify(event, null, 2));

    var bucket = event.Records[0]['s3']['bucket']['name'];

    var en = event.Records[0]['eventName'];

    var et = event.Records[0]['eventTime'];

    var key = event.Records[0]['s3']['object']['key'];

    var sip = event.Records[0]['requestParameters']['sourceIPAddress'];

    var params1 = {Bucket: bucket, Key: key}; 

    s3.getObject( params1, function(err,data) {

        if(err) {

            console.log(err.stack);

            callback(err);

        } else {

            var value = data.Body.toString('ascii')

            console.log(data);

            console.log("Raw text:\n" + value);

            var params2 = {

                TableName: "pi-sensor",

                Item:{

                    "id": et,

                    "event" : en,

                    "bucket": bucket,

                    "key" : key,

                    "sip": sip,

                    "value" : value

                }

            };

            console.log("Gettings IoT device details...");

            //S3 to DynamoDB

            dynamo.put(params2, function(err, data) {

                if(err) {

                    console.error("Unable to post devices. Error JSON:", JSON.stringify(err, null, 2));

                    context.fail();

                } else {

                    console.log("keepet data:", JSON.stringify(data, null, 2));

                    context.succeed('success post');

                }

            });

        }

    });

}

7. Lambda : s3 put event sample

8. Lambda : Context Sample

9. Lambda : S3 Object GET Data Sample

AWS IoT Core + Raspberry Pi + AWS IoT Device SDK for Java [P021]

https://www.youtube.com/watch?v=xhVIT6XJ01s

GitHub : https://github.com/rdiot/rdiot-p021

* Parts

- Raspberry Pi2

- Temperature and humidity DHT11 sensor module (KY-015) [S008]

* Contents

1. Sample Test (basic publish)

- install maven3 in pi

- download maven3 : https://fossies.org/linux/misc/apache-maven-3.5.3-bin.tar.gz/

$ tar zxvf apache-maven-3.5.3-bin.tar.gz

$ export PATH=/home/pi/AWSIoT/apache-maven-3.5.3/bin:$PATH

- com.amazonaws.services.iot.client.sample.pubSub.PublishSubscribeSample

- download root ca certificate and install aws device sdk for java

- run pub/sub sample 

$ unzip http://connect_device_package.zip

$ ./start.sh

mvn exec:java -pl aws-iot-device-sdk-java-samples -Dexec.mainClass="com.amazonaws.services.iot.client.sample.pubSub.PublishSubscribeSample" -Dexec.args="-clientEndpoint <prefix>.iot.<region>.amazonaws.com -clientId <unique client id> -certificateFile <certificate file> -privateKeyFile <private key file>"

[INFO] BUILD SUCCESS

[INFO] ------------------------------------------------------------------------

[INFO] Total time: 04:15 min

[INFO] Finished at: 2018-06-01T13:43:37Z

[INFO] ------------------------------------------------------------------------

Running pub/sub sample application...

[INFO] Scanning for projects...

[INFO] Inspecting build with total of 1 modules...

[INFO] Installing Nexus Staging features:

[INFO]   ... total of 1 executions of maven-deploy-plugin replaced with nexus-staging-maven-plugin

[INFO] 

[INFO] -----------< com.amazonaws:aws-iot-device-sdk-java-samples >------------

[INFO] Building aws-iot-device-sdk-java-samples 1.1.1

[INFO] --------------------------------[ jar ]---------------------------------

[INFO] 

[INFO] --- exec-maven-plugin:1.6.0:java (default-cli) @ aws-iot-device-sdk-java-samples ---

Cert file:../RaspberryPi.cert.pem Private key: ../RaspberryPi.private.key

Jun 01, 2018 1:43:59 PM com.amazonaws.services.iot.client.core.AwsIotConnection onConnectionSuccess

INFO: Connection successfully established

Jun 01, 2018 1:43:59 PM com.amazonaws.services.iot.client.core.AbstractAwsIotClient onConnectionSuccess

INFO: Client connection active: sdk-java

1527860639952: >>> hello from blocking publisher - 1

1527860639952: >>> hello from non-blocking publisher - 1

1527860639973: <<< hello from blocking publisher - 1

1527860639989: <<< hello from non-blocking publisher - 1

1527860640953: >>> hello from non-blocking publisher - 2

1527860640964: >>> hello from blocking publisher - 2

1527860640995: <<< hello from non-blocking publisher - 2

1527860641042: <<< hello from blocking publisher - 2

1527860641953: >>> hello from non-blocking publisher - 3

1527860641979: <<< hello from non-blocking publisher - 3

2. Develop

- Requirements : +java1.7, aws-iot-device-sdk-java 1.1.1, Jackson 2.x, Paho MQTT client for Java 1.1.x, pi4j

- Install the SDK using Maven

 <dependency>

    <groupId>com.amazonaws</groupId>

    <artifactId>aws-iot-device-sdk-java</artifactId>

    <version>1.1.1</version>

</dependency>

<dependency>

    <groupId>com.amazonaws</groupId>

    <artifactId>aws-iot-device-sdk-java-samples</artifactId>

    <version>1.1.1</version>

</dependency>

- source : https://github.com/rdiot/rdiot-p021/blob/master/src/main/java/com/rdiot/awsiot/App.java

3. Setup AWS IoT Core 

4. Package Download 

5. AWS IoT Rule Setup 

- Rule Name : email_notification

- Description : when temperature is over 30 degrees.

- Rule Query : SELECT temperature as t, humidity as h FROM 'sensor/dht11' WHERE temperature > 30

- Actions 
 1) SNS : sendEmail 

 2) Republish : sensor/dht11/over30

6. run application

$ java -Dpi4j.linking=dynamic -jar awsiot-0.0.1-SNAPSHOT.jar (run.sh)

7. Monitoring

8. Action Check over 30 degrees

- republish to sensor/dht11/over30

- notification sns : email

- Reference

GitHub AWS IoT Device SDK for Java : https://github.com/aws/aws-iot-device-sdk-java/blob/master/README.md

API Document : http://aws-iot-device-sdk-java-docs.s3-website-us-east-1.amazonaws.com/

Sample Code : https://github.com/aws/aws-iot-device-sdk-java/blob/master/aws-iot-device-sdk-java-samples/src/main/java/com/amazonaws/services/iot/client/sample/pubSub/PublishSubscribeSample.java

RGB LED Controller Dimmer 3 Channel DC12V - 24V 9A [B206]

https://www.youtube.com/watch?v=tsadcDA8O5M

* Specs

This LED Dimmer/RGB Controller can be used as a 3 channels LED single color strip light dimmer a LED RGB module / Flexible LED Strips as a static color controller.

Universal Red/Green/Blue(RGB) dimmer-konbs can be used to adjust Red, Green and Blue from 0 to 100 percent for full range color creation. Endless RGB color combinations.

Installation is quite easy, power up the unit with 12 to 24V DC power source and connect 3 output connection to RGB LED strip light or a Solid Color LED strip light. Electric wires and cables are easily connected to the unit through screw down connectors, which makes 100% secure connections.

Applications:

For RGB LED strip controlling and dimming each color independently.

For solid color LED strip with 3 independent channels

For dynamic White LED strip, controlling color temprature

For RGB modules

Input voltage: DC12V-24V, 108W (12V )/ 316W (24V)

Output: 3 channel

Max load current: 3 Amps/channel (9 Amps total)

IP rating: IP-55

Size:5.12*2.62*2 inches

* Contents

- LEFT Connect 

+ - 12V

- - GND

- RIGHT Connect

COM - +

R - R

G - G

B - B

Samsung SmartThings Home Monitoring Kit [P020]

https://www.youtube.com/watch?v=d8WQEuLjbC0

* Parts

Samsung SmartThings Hub (STH-ETH-250) [B195]

Samsung SmartThings Multipurpose Sensor (F-MLT-US-2) [S254] 

Samsung SmartThings Motion Sensor (F-IRM-US-2) [S255] 

Samsung SmartThings Dimming Outlet (F-CEN-DIM-1) [S256] 

* Contents

1. SmartThings Classic Mobile App > Automation > Add a SmartApp

2. Configure Smart Lighting Automations

3. Automation Routines : "Door Open"

Samsung SmartThings Dimming Outlet (F-CEN-DIM-1) [S256]

https://www.youtube.com/watch?v=gzb1YHhziaM

* Specs

- Description

Dim your lights to fit your mood.

Control standard plug-in lamps and other plug-in lighting devices.

Requires a SmartThings Hub or a compatible device with SmartThings Hub functionality.

Control your SmartThings Outlet and other connected devices with the SmartThings app for iPhone or Android.

Automate your SmartThings Outlet and set it to turn on or off when doors are opened, when there’s activity in your home, and much more.

Manage your SmartThings Outlet and other connected devices with SmartThings Routines for Good Morning, Goodbye, Good Night, and more.

Control your SmartThings Outlet with voice commands using SmartThings and the Google Assistant or Amazon Alexa.

- Specs

Model number: F-CEN-DIM-1

Power source: Wall-Powered

Weight: 0.25 lb

Dimensions: 2" x 2" x 2.5"

Protocol: ZigBee

* Contents

1. Reset the Outlet Sensor and then Add a Thing

2. Added the Outlet Sensor

3. Select the Outlet Sensor

4. Setup Automation > SmartApps 

5.Add a SmartApps > SmartThings Recommends

6. SmartThings Recommends > Smart Lights

7. Select : Which devices do you want to control?

8. Setting : When Mode Changes to Night, Turn On the Outlet Sensor.

9. Good Night Routine : Mode Change to Night

   Goodbye! Routine : Mode Change to Away

- Reference

https://shop.smartthings.com/products/samsung-smartthings-dimming-outlet/631

https://www.samsung.com/us/smart-home/smartthings/

https://www.samsung.com/us/smart-home/smartthings/kits/

Samsung SmartThings Motion Sensor (F-IRM-US-2) [S255]

https://www.youtube.com/watch?v=v-EWr0Zb34M

* Specs

- Description

Add a little smartness to your things

Monitor motion and temperature.

Requires a SmartThings Hub or a compatible device with SmartThings Hub functionality.

Monitor your Motion Sensor and other connected devices with the SmartThings app for iPhone or Android.

Receive alerts from SmartThings if your Motion Sensor detects movement, or if the temperature changes.

Automate connected devices with SmartThings and set them to turn on or off if your Motion Sensor detects movement, or if the temperature changes.

- Specs

Model number: F-IRM-US-2

Power source: Battery : CR2450

Color: White

Weight: 0.08 lb

Dimensions: 0.8" x 2" x 2"

Protocol: ZigBee

Battery type: CR-2477

* Contents

- Connect 

1. Add Thing : Motion Sensor

2. added Motion Sensor 

3. when click the motion sensor : status

4. Add Automation Routine

5. Add a Routine : name is "who"

6. Setting : Change the mode to "home"

7. Automatically perform "who" : select "Things start happening"

8. Perform : Which : Motion Sensor

9. Successfully added Things Start Happening

10. Notification 

- Reference

https://shop.smartthings.com/products/samsung-smartthings-motion-sensor

https://www.samsung.com/us/smart-home/smartthings/

https://www.samsung.com/us/smart-home/smartthings/kits/

Samsung SmartThings Multipurpose Sensor (F-MLT-US-2) [S254]

https://www.youtube.com/watch?v=v7Lrxuk4FL8

* Specs

- Description

Add a little smartness to your things.

Monitor doors and windows.

Monitor temperature and orientation.

Requires a SmartThings Hub or a compatible device with SmartThings Hub functionality.

Monitor your Multipurpose Sensor and other connected devices with the SmartThings app for iPhone or Android.

Receive alerts from SmartThings if your Multipurpose Sensor detects that doors and windows have been opened or left open, or if the temperature changes.

Automate connected devices with SmartThings and set them to turn on or off if your Multipurpose Sensor detects that doors and windows have been opened or left open, or if the temperature changes.

- Specs

Model number: F-MLT-US-2

Power source: Battery

Color: White

Weight: 0.1 lb

Dimensions: 0.57" x 1.35" x 1.9"

Protocol: ZigBee

Battery type: CR-2450 battery

* Contents

1. Add a Things : Multipurpose Sensor 

- If your device doesn't connect, Then press the Connect Button.

2. Devices found and then Save : Multipurpose Sensor 

3. You can see the Multipurpose Sensor Thing

4. Add a Routine to get push notification when open and close

- write the routine name : Door Open

- Change the mode : home

- Additional settings : Automatically perform "Door Open"

 : Select "Something Opens or Closes"

- Advanced Options : Don't automatically do this if I am in one of these modes : none

- On the push notification 

added "Door Open" Routine

5. When the multipurpose sensor is open or close

- Reference

https://www.samsung.com/us/smart-home/smartthings/

https://www.samsung.com/us/smart-home/smartthings/kits/

https://shop.smartthings.com/products/samsung-smartthings-multipurpose-sensor

Samsung SmartThings Hub (STH-ETH-250) [B195]

https://www.youtube.com/watch?v=ERabX0zL7ag

* Specs

- Description

The brain of your smart home.

Connect wirelessly with a wide range of smart devices and make them work together.

Monitor and control connected devices in your home using a single SmartThings app for iPhone or Android.

Receive alerts from connected devices when there’s unexpected activity in your home.

Automate connected devices in your home and set them to turn on or off when doors are opened, as people come and go, and much more.

Manage connected devices in your home with SmartThings Routines for Good Morning, Goodbye, Good Night, and more.

Control connected devices in your home with voice commands using SmartThings and Amazon Alexa or Google Home.

Requires an internet-connected Wi-Fi router with an available ethernet port, plus the free SmartThings app for Android (4.1 or later) or iPhone (iOS 9.0 or later).

- Specs

Model number: STH-ETH-250

Power source: Battery, Wall-Powered

Color: White

Weight: 7.68 oz

Dimensions: 4.2" x 4.9" x 1.3"

Protocol: ZigBee, Z-Wave, Cloud-to-Cloud, LAN

Battery type: 4 AA batteries

* Contents

1. Install SmartThings Hub

- It needs welcome code (6 digit)

- power : AA battery 4ea or AC

2. Connect to SmartThings Hub and SmartThings Classic Mobile App

- add new SmartThings User

- create Samsung Account 

- After login, Confirm your country

- Enter Code for activate your SmartThings secure Code.

- Connect your Hub 

- Setup your location

- Setting up your hub

- Setup success!

- Adjust Battery Settings

- Finished

- Status Check : Hub is Online in menu

- Reference

https://shop.smartthings.com/products/samsung-smartthings-hub

Pi4J + Amazon S3 REST API + Amazon Athena [P019]

https://www.youtube.com/watch?v=G-Ot7oh4_jk

GitHub : https://github.com/rdiot/rdiot-p019.git

* Parts

- Raspberry Pi2

- Temperature and humidity DHT11 sensor module (KY-015) [S008]

* Contents

- Connect 

S - Signal GPIO3

middle - VCC

- - GND

1. Getting sensor value by Pi4J (Java I/O library for the Raspberry Pi) and then upload to amazon s3.

 : Run the java application

$ java -Dpi4j.linking=dynamic -jar pi4j_s3rest-0.0.1-SNAPSHOT.jar

2. Check the upload status in the amazon console. (s3)

3. Setup Amazon Athena .

- add database : pisensor

- add table : temperature

- DDL (add table)

CREATE EXTERNAL TABLE IF NOT EXISTS piSensor.temperature (

  `name` string,

  `value` float 

)

ROW FORMAT SERDE 'org.openx.data.jsonserde.JsonSerDe'

WITH SERDEPROPERTIES (

  'serialization.format' = '1'

) LOCATION 's3://rdkim-test/'

TBLPROPERTIES ('has_encrypted_data'='false');

4. SQL Query in the Amazon Athena

example : SELECT * FROM "pisensor"."temperature" limit 10;

- Pi4J Java Maven

<dependency>

    <groupId>com.pi4j</groupId>

    <artifactId>pi4j-core</artifactId>

   <version>1.1</version>

</dependency>

- project maven pom.xml 

 : https://github.com/rdiot/rdiot-p019/blob/master/pom.xml

- source : main : https://github.com/rdiot/rdiot-p019/blob/master/pi4j_s3rest/App.java

- source : pi4j : https://github.com/rdiot/rdiot-p019/blob/master/pi4j/dht11.java

- source : s3 rest api header aws sig4 : https://github.com/rdiot/rdiot-p019/blob/master/s3rest/auth/AWS4SignerForAuthorizationHeader.java

- Key Code

     dht11 dht = new dht11();

        for (int i=0; i<10; i++) {

            try {

Thread.sleep(2000);

} catch (InterruptedException e) {

e.printStackTrace();

}

            objectContent = dht.getTemperature();

            if(objectContent != null) {

        System.out.println(objectContent);

        putS3Object(bucketName, regionName, awsAccessKey, awsSecretKey);

            break;

            }            

         }     

- Reference

 : Pi4J Project : http://pi4j.com

 : Pi4J GitHub : https://github.com/Pi4J/pi4j

 : get dht11 : https://stackoverflow.com/questions/28486159/read-temperature-from-dht11-using-pi4j

 : Amazon S3 Rest API : https://docs.aws.amazon.com/AmazonS3/latest/API/Welcome.html

Amazon Polly + Google Home + Sonoff wifi [P018]

https://www.youtube.com/watch?v=IX2mUb73he8

GitHub : https://github.com/rdiot/rdiot-p018.git

* Parts

- Google Home AI Speaker [B187]

- Sonoff ITEAD WiFi Switch Module (ESP8266) [S198]

- Amazon Polly TTS [P017]

* Contents

- Install AWS CLI in Raspberry Pi

$ wget https://s3.amazonaws.com/aws-cli/awscli-bundle.zip

$ unzip awscli-bundle.zip 

$ sudo ./install -i /usr/local/aws -b /usr/local/bin/aws

- Config AWS CLI

$ aws configure

- Java amazon polly development

 : maven : pom.xml : https://github.com/rdiot/rdiot-p018/blob/master/pom.xml

 : Source : https://github.com/rdiot/rdiot-p018/blob/master/PollyDemo.java

 : Binary : polly_sonoff.tar.gz

 : command.txt : ON or OFF 

- Sonoff Work with Google Home 

- How to connect Sonoff smart ewelink to Google Assistant

1) Tap Home control in Googlt Home App Menu

2) Uner Devices, tap the + icon in the bootom right. (add devices)

3) Tap Smart We Link 

4) Enter Your eWeLink account email/phone number. (need countrycode and account, password)

5) After Logging in successfully, it will display the device.

- Run java amazon polly application

$ java - jar polly-0.0.1-SNAPSHOT.jar 

Raspberry Pi Camera 5MP Night Version (SEN0184) [S280]

https://www.youtube.com/watch?v=HhDAtAHRuQ8

* Specs

Camera: 5 million pixels

Photosensitive Module: OV5647

Camera Parameters:

CCD size: 1/4 inches

Aperture (f): 1.8

Focal Length: 3.6MM (adjustable)

Diagonal: 75.7 degrees

Sensor best PIX: 1080p

4 Screw Holes

Can be used in a fixed position

3.3V external power supplies

Supports access to the infrared light or fill light

Dimension: 25mm x 24mm

* Contents

- Capture still image

$ raspistill -t 30000 -o rdiot.jpg

- Capture video

$ raspivid -t 10000 -o video.h264

- Capture Night Test

- Capture Day Test

- Download Capture File Sample : 

- Reference 

 : RASPICAM COMMANDS : https://www.raspberrypi.org/documentation/usage/camera/raspicam/README.md

Amazon Polly TTS(Text to Speech) [P017]

https://www.youtube.com/watch?v=1ehU_bueWdQ

GitHub : https://github.com/rdiot/rdiot-p017.git

* Specs

Amazon Polly is a service that turns text into lifelike speech, allowing you to create applications that talk, and build entirely new categories of speech-enabled products. Amazon Polly is a Text-to-Speech service that uses advanced deep learning technologies to synthesize speech that sounds like a human voice.

With dozens of lifelike voices across a variety of languages, you can select the ideal voice and build speech-enabled applications that work in many different countries.

* Contents

- Install AWS CLI in Raspberry Pi

$ wget https://s3.amazonaws.com/aws-cli/awscli-bundle.zip

$ unzip awscli-bundle.zip 

$ sudo ./install -i /usr/local/aws -b /usr/local/bin/aws

- config AWS CLI

$ aws configure

- java amazon polly library and text file

- run amazon polly application

- binary library download : polly.tar.gz

- maven dependency 

 : https://github.com/rdiot/rdiot-p017/blob/master/pom.xml

<dependency>

<groupId>com.amazonaws</groupId>

<artifactId>aws-java-sdk-polly</artifactId>

<version>1.11.77</version>

</dependency>

<!-- https://mvnrepository.com/artifact/com.googlecode.soundlibs/jlayer -->

<dependency>

<groupId>com.googlecode.soundlibs</groupId>

<artifactId>jlayer</artifactId>

<version>1.0.1-1</version>

</dependency>

- Souce Code

 : https://github.com/rdiot/rdiot-p017/blob/master/PollyDemo.java

package com.rdiot.polly;

import java.io.BufferedReader;

import java.io.FileInputStream;

import java.io.IOException;

import java.io.InputStream;

import java.io.InputStreamReader;

import com.amazonaws.ClientConfiguration;

import com.amazonaws.auth.DefaultAWSCredentialsProviderChain;

import com.amazonaws.regions.Region;

import com.amazonaws.regions.Regions;

import com.amazonaws.services.polly.AmazonPollyClient;

import com.amazonaws.services.polly.model.DescribeVoicesRequest;

import com.amazonaws.services.polly.model.DescribeVoicesResult;

import com.amazonaws.services.polly.model.OutputFormat;

import com.amazonaws.services.polly.model.SynthesizeSpeechRequest;

import com.amazonaws.services.polly.model.SynthesizeSpeechResult;

import com.amazonaws.services.polly.model.Voice;

import javazoom.jl.player.advanced.AdvancedPlayer;

import javazoom.jl.player.advanced.PlaybackEvent;

import javazoom.jl.player.advanced.PlaybackListener;

public class PollyDemo {

private final AmazonPollyClient polly;

private final Voice voice;

//private static final String SAMPLE = "Polly Test";

private static String SAMPLE;

public PollyDemo(Region region) {

// create an Amazon Polly client in a specific region

polly = new AmazonPollyClient(new DefaultAWSCredentialsProviderChain(), 

new ClientConfiguration());

polly.setRegion(region);

// Create describe voices request.

DescribeVoicesRequest describeVoicesRequest = new DescribeVoicesRequest().withLanguageCode("en-US");

// Synchronously ask Amazon Polly to describe available TTS voices.

DescribeVoicesResult describeVoicesResult = polly.describeVoices(describeVoicesRequest);

voice = describeVoicesResult.getVoices().get(0);

}

public static String roadLocalFile(String filepath) {

    String readFile= "";

    try {

        BufferedReader in = new BufferedReader(new InputStreamReader(new FileInputStream(filepath),"UTF-8"));

        String s;

        while ((s = in.readLine()) != null) {

            readFile+= s;

        }

        in.close();

    } catch (IOException e) {

        System.err.println(e);

        System.exit(1);

    }

    return readFile;

}

public InputStream synthesize(String text, OutputFormat format) throws IOException {

SynthesizeSpeechRequest synthReq = 

new SynthesizeSpeechRequest().withText(text).withVoiceId(voice.getId())

.withOutputFormat(format);

SynthesizeSpeechResult synthRes = polly.synthesizeSpeech(synthReq);

return synthRes.getAudioStream();

}

public static void main(String args[]) throws Exception {

SAMPLE = roadLocalFile("./text.txt");

//create the test class

PollyDemo helloWorld = new PollyDemo(Region.getRegion(Regions.AP_NORTHEAST_2));

//get the audio stream

InputStream speechStream = helloWorld.synthesize(SAMPLE, OutputFormat.Mp3);

//create an MP3 player

AdvancedPlayer player = new AdvancedPlayer(speechStream,

javazoom.jl.player.FactoryRegistry.systemRegistry().createAudioDevice());

player.setPlayBackListener(new PlaybackListener() {

@Override

public void playbackStarted(PlaybackEvent evt) {

System.out.println("#################################################################");

System.out.println("RD IoT Amazon Polly TTS");

System.out.println("#################################################################");

System.out.println("Playback started");

System.out.println("-----------------------------------------------------------------");

System.out.println("TTS : " + SAMPLE);

}

@Override

public void playbackFinished(PlaybackEvent evt) {

System.out.println("-----------------------------------------------------------------");

System.out.println("Playback finished");

System.out.println("#################################################################");

}

});

// play it!

player.play();

}

}

USB Microphone [S281]

https://www.youtube.com/watch?v=ChITet6OuxM

* Specs

Product parameters:

The sensitivity: - 47 db + 4 db

Lower sensitivity: - 3 db at 1.5 V

Working voltage: 4.5 V

The frequency response: 100 to 16 KHZ

SNR: wining - 67 db

Line length: 0.7 to 0.9 M

* Contents

- Check Device

$ lsusb

$ dmesg

- Setup 

$ sudo vi /usr/share/alsa/alsa.conf

defaults.ctl.card 0 => 1

defaults,pcm, card 0 => 1

- Setup Volume

$ alsamixer 

- Recording

$ arecord -D plughw:1,0 -c 1 -f S16_LE -r 44100 test.wav

- Play 

$ aplay test.wav

USB 2.0 Microphone Speech MIC Audio Adapter Driver [S278]

https://www.youtube.com/watch?v=Zw0uAvTD8n0

* Specs

Brand Name: ANBES

Set Type: Single Microphone

Communication: Wireless

Transducer: Condenser Microphone

Use: Computer Microphone

Model Number: USB Microphone

Polar Patterns: Omnidirectional

Package: No

Style: Computer Microphone

Item Name: Computer Microphone

* Contents

- Check Device

$ lsusb

$ dmesg

- Setup 

$ sudo vi /usr/share/alsa/alsa.conf

defaults.ctl.card 0 => 1

defaults,pcm, card 0 => 1

- Setup Volume

$ alsamixer 

- Recording

$ arecord -D plughw:1,0 -c 1 -f S16_LE -r 44100 test.wav

- Play 

$ aplay test.wav

Xiaomi Yeelight Candle Light [D090]

https://www.youtube.com/watch?v=qxB2_IPN0Ws

* Specs

- Description

Candela is the world's only smart candlelight using the latest Bluetooth (BLE) Mesh technology, combining the warm comfort of candlelight with the convenience and control of smart technology. The BLE Mesh technology allows up to 30,000 units Candelas to communicate with each other.

Control your candela and other YEELIGHT smart lights with our Android or iOS apps

The built-in 2100Mah battery allows for up to 8 hours of continuous use on a single charge. The portability lets candela fits in any moment of your life

Visual comfort light, the candela holds an 1800K Color temperature, which is the same Color temperature as candlelight, with adjustable brightness, leading to the warm familiar Copper of candlelight

Distinctive Design, Candela’s final design was the sum effort of 4 months collaboration with multinational design teams

Top quality materials, we want to fully load the lamp, offering a timeless piece with minimalist design components while using top quality materials to bring you the luxury product experience

Multiple lights, countless displays

A warm candle light for a heart-warming feeling

Your remote to a beautiful candlelit night

Intricately designed, a touchable artwork

Built-in rechargeable battery for a long-lasting life

- Specs

Brand YEELIGHT

Model Candela, LED Candle light,

Item Weight 1.4 pounds

Product Dimensions 4 x 4 x 10 inches

Item model number YLFW01YL

UPC 608887786279

Batteries: 1 Lithium Metal batteries required. (included)

Color Gold

Style Modern

Material Aluminum

Shape Circular

Power Source battery-powered

Item Package Quantity 1

Batteries Included? Yes

Batteries Required? Yes

Battery Cell Type Lithium Metal

Cover Included Candela, USB Cable

Bulb Type LED

Voltage 5 volts

Wattage 5 watts

* Contents

- yeelight app : https://play.google.com/store/apps/details?id=com.yeelight.cherry

- yeelight cancle ble advertise before pairing

 Google Home AI Speaker [B187]

https://www.youtube.com/watch?v=swZtIL98IKY

* Specs

Dimensions

Diameter: 3.79 in (9B6.4 mm)

Height: 5.62 in (142.8 mm)

Power cable: 70.8 in (1.8 m)

Weight

Device: 1.05 lbs (477 g)

Power adapter: 4.58 oz (130 g)

Colors

Body: White

Base: Standard base is slate fabric.

Supported Audio Formats

HE-AAC, LC-AAC+, MP3, Vorbis, WAV (LPCM), FLAC with support for high-resolution streams

Wireless network

802.11b/g/n/ac (2.4GHz/5Ghz) Wi-Fi for high-performance streaming

Note: WPA2-Enterprise is not supported.

Speaker