RWaltersMA

SAMPLE STREAM SOLAR

//Create the Stream Processor and add the sample_stream_solar connection registry connection first

//Create variablre for source connection

solar={$source:{connectionName:'sample_stream_solar',  timeField: { $dateFromString: { dateString: '$timestamp' }}}}


// Observe sample data

RWaltersMA

{"exportVersion":4,"dashboards":{"dashboard-1":{"description":"","filters":[],"layout":[{"w":9,"h":2,"x":0,"y":2,"i":"item-1","minW":1,"maxW":10,"minH":1,"maxH":10,"moved":false,"static":false,"isDraggable":true,"isResizable":true},{"w":9,"h":2,"x":0,"y":4,"i":"item-2","minW":1,"maxW":10,"minH":1,"maxH":10,"moved":false,"static":false,"isDraggable":true,"isResizable":true},{"w":2,"h":2,"x":0,"y":0,"i":"item-3","minW":1,"maxW":10,"minH":1,"maxH":10,"moved":false,"static":false,"isDraggable":true,"isResizable":true},{"i":"item-4","x":2,"y":0,"w":2,"h":2,"minW":1,"minH":1,"maxW":10,"maxH":10,"moved":false,"static":false,"isDraggable":true,"isResizable":true},{"i":"item-5","x":4,"y":0,"w":2,"h":2,"minW":1,"minH":1,"maxW":10,"maxH":10,"moved":false,"static":false,"isDraggable":true,"isResizable":true}],"title":"kafkaPerformanceSource"}},"items":{"item-1":{"allowInteractiveFilters":true,"calculatedFields":[],"channels":{"x":{"channelType":"category","field":"timestampColumn","inferredType":"Date","type":"nominal","

RWaltersMA

{"exportVersion":4,"dashboards":{"dashboard-1":{"description":"","filters":[{"type":"Date","disabled":false,"name":"_insertedTS","settings":{"type":"absolute","absolute":{"from":{"enabled":true,"date":"2021-07-27","time":"17:30:00","inclusive":true},"to":{"enabled":false,"date":null,"time":"00:00:00","inclusive":false},"timezone":"Europe/Paris"},"relative":{"from":{"enabled":false,"tense":null,"value":"","unit":null},"until":{"enabled":false,"tense":null,"unit":"days","value":""}},"period":{"direction":"previous","count":"1","unit":"day","includeCurrent":true}},"linkedFields":[{"dataSourceId":"data-source-1","fieldPath":"_insertedTS"}]}],"layout":[{"w":10,"h":2,"x":0,"y":1,"i":"item-1","minW":1,"maxW":10,"minH":1,"maxH":10,"moved":false,"static":false,"isDraggable":true,"isResizable":true},{"w":10,"h":2,"x":0,"y":3,"i":"item-2","minW":1,"maxW":10,"minH":1,"maxH":10,"moved":false,"static":false,"isDraggable":true,"isResizable":true},{"w":2,"h":1,"x":0,"y":0,"i":"item-3","minW":1,"maxW":10,"minH":1,"maxH":10,"m

RWaltersMA

#Updated 2-15-19 changed from storing epoch time in integers to ISODate (mitigating Y2038 problem)
import random
import csv
import argparse
import pymongo
from datetime import date, timedelta
from datetime import datetime as dt
import threading
import sys
import json

RWaltersMA

const mongodb = require("mongodb");

run().catch(error => console.error(error));

async function run() {
  console.log(new Date(), "Connecting to localhost");
  const uri = "mongodb://127.0.0.1:27017/test?replicaSet=repl0";
  const client = await mongodb.MongoClient.connect(
    uri,
    function(err, client) {

RWaltersMA

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using MongoDB.Bson;
using MongoDB.Driver;
using MongoDB.Bson.Serialization.Attributes;

namespace MongoDBTransaction

RWaltersMA

using System;
using System.IO;
using System.Threading.Tasks;
using Microsoft.AspNetCore.Mvc;
using Microsoft.Azure.WebJobs;
using Microsoft.Azure.WebJobs.Extensions.Http;
using Microsoft.AspNetCore.Http;
using Microsoft.Azure.WebJobs.Host;
using Microsoft.Extensions.Logging;
using Newtonsoft.Json;

RWaltersMA

exports = function(payload,response) {
  
  const mongodb = context.services.get("mongodb-atlas");
  const sensordata = mongodb.db("iotdb").collection("sensordata");
  
  var body = {};
  if (payload.body) {
    
    try{
      

RWaltersMA

import hashlib;
import hmac;
import datetime;
import paho.mqtt.client as mqtt
import json
import calendar
import requests

mqqt_server=#enter your mqqt server here
mqqt_port=1883

RWaltersMA

from umqtt.simple import MQTTClient
import network
import machine
import time
import socket
import utime

ssid=#Put your SSID name here
pwd=#Put your WiFi password here
device_name='TempSensor1' #Put the name of the device here