Here are all of the videos I’ve made for this project:
So basically this project was kind of my first sponsored project! I got the arduino for free and all of the parts I used got paid for by MIT as well. You can check out all of the smaller steps I did the for the project at MIT’s project tracking site, Build In Progress.
Thanks MIT!
So, once you get processing for android all installed, if you’re like me the first thing you’ll want to do is get your phone talking with an Arduino over bluetooth. Well maybe not first thing but you get the Idea. Below is two pieces of code that I’ve used for this project. It’s very specific for this project, but it may help somebody and will likely help myself in the future so there you go.
Ardiuno Code:
const char EOPmarker = '.'; //This is the end of packet marker
char serialbuf[32]; //This gives the incoming serial some room. Change it if you want a longer incoming.
char serialbuf2[32];
#include <string.h> // we'll need this for subString
#define MAX_STRING_LEN 20 // like 3 lines above, change as needed.
#include <SoftwareSerial.h>
SoftwareSerial Ble(11, 10); // RX, TX
int Mode = 5;
int Shutter = 6;
int Focus = 7;
void setup(){
Serial.begin(9600);
Ble.begin(9600);
pinMode(Mode, INPUT);
pinMode(Shutter, OUTPUT);
pinMode(Focus, OUTPUT);
}
void loop() {
if (Serial.available() > 0) { //makes sure something is ready to be read
static int bufpos = 0; //starts the buffer back at the first position in the incoming serial.read
char inchar = Serial.read(); //assigns one byte (as serial.read()'s only input one byte at a time
if (inchar != EOPmarker) { //if the incoming character is not the byte that is the incoming package ender
serialbuf[bufpos] = inchar; //the buffer position in the array get assigned to the current read
bufpos++; //once that has happend the buffer advances, doing this over and over again until the end of package marker is read.
}
else { //once the end of package marker has been read
serialbuf[bufpos] = 0; //restart the buff
bufpos = 0; //restart the position of the buff
Expose(serialbuf,1);
}
}
if (Ble.available() > 0) { //makes sure something is ready to be read
static int bufpos2 = 0; //starts the buffer back at the first position in the incoming serial.read
char inchar2 = Ble.read(); //assigns one byte (as serial.read()'s only input one byte at a time
if (inchar2 != EOPmarker) { //if the incoming character is not the byte that is the incoming package ender
serialbuf2[bufpos2] = inchar2; //the buffer position in the array get assigned to the current read
bufpos2++; //once that has happend the buffer advances, doing this over and over again until the end of package marker is read.
delay(10);
}
else { //once the end of package marker has been read
serialbuf2[bufpos2] = 0; //restart the buff
bufpos2 = 0; //restart the position of the buff
Expose(serialbuf2,0);
}
}
}
void Expose(char* buf, int Mode){
int Type = atoi(subStr(buf, ",", 1));
int Exposures = atoi(subStr(buf, ",", 2));
int Delay = atoi(subStr(buf, ",", 3));
int Actual_Delay = Delay;
String Out = String("Mode: " + String(Mode) + " Type: " + String(Type) + " Exposures: " + String(Exposures) + " Delay: " + String(Delay));
Serial.println(Out);
for (int i = 0; i < Exposures; i++){
if (Type == 0){
digitalWrite(Shutter, HIGH); // turn the LED on (HIGH is the voltage level)
delay(30); // wait for a second
digitalWrite(Shutter, LOW); // turn the LED off by making the voltage LOW
delay(30);
if (Delay < 250){
Actual_Delay = 250;
}
else {
Actual_Delay = Delay;
}
}
if (Type == 1){
digitalWrite(Focus, HIGH); // turn the LED on (HIGH is the voltage level)
delay(30); // wait for a second
digitalWrite(Focus, LOW); // turn the LED off by making the voltage LOW
delay(30);
delay(100);
digitalWrite(Shutter, HIGH); // turn the LED on (HIGH is the voltage level)
delay(30); // wait for a second
digitalWrite(Shutter, LOW); // turn the LED off by making the voltage LOW
delay(30);
if (Delay < 700){
Actual_Delay = 700;
}
else {
Actual_Delay = Delay;
}
}
delay(Actual_Delay);
}
}
// below is just function logic, which I do not fully understand. but it works.
char* subStr (char* input_string, char *separator, int segment_number) {
char *act, *sub, *ptr;
static char copy[MAX_STRING_LEN];
int i;
strcpy(copy, input_string);
for (i = 1, act = copy; i <= segment_number; i++, act = NULL) {
sub = strtok_r(act, separator, &ptr);
if (sub == NULL) break;
}
return sub;
}
Processing Code:
import apwidgets.*;
//App-Wide (General) Elements
APWidgetContainer General_Container;
APRadioButton General_Setup_RB;
APRadioButton General_Interact_RB;
APRadioGroup General_RadioGroup;
//Setup Mode Elements
APWidgetContainer SetupMode_Container;
APButton SetupMode_ConnectButton;
APButton SetupMode_DisconnectButton;
//Interact Mode Elements
APWidgetContainer InteractMode_Container;
APButton InteractMode_SendButton;
APEditText InteractMode_TypeTB;
APEditText InteractMode_ExposuresTB;
APEditText InteractMode_DelayTB;
/* -------------- Bluetooth Stuff -------------- */
//required for BT enabling on startup
import android.content.Intent;
import android.os.Bundle;
import ketai.net.bluetooth.*;
import ketai.ui.*;
import ketai.net.*;
import oscP5.*;
KetaiBluetooth bt;
String info = "";
KetaiList klist;
PVector remoteMouse = new PVector();
ArrayList<String> devicesDiscovered = new ArrayList();
boolean isConfiguring = true;
String UIText;
//********************************************************************
// The following code is required to enable bluetooth at startup.
//********************************************************************
void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
bt = new KetaiBluetooth(this);
}
void onActivityResult(int requestCode, int resultCode, Intent data) {
bt.onActivityResult(requestCode, resultCode, data);
}
void setup(){
//App-Wide (General) Elements
General_Container = new APWidgetContainer(this); //create new container for widgets
General_RadioGroup = new APRadioGroup(10, 10); //create a new radiogroup
General_RadioGroup.setOrientation(APRadioGroup.HORIZONTAL);
General_Setup_RB = new APRadioButton("Setup "); //create new radiobutton from label.
General_Interact_RB = new APRadioButton("Interact "); //create new radiobutton from label.
General_RadioGroup.addRadioButton(General_Setup_RB); //place radiobutton in radiogroup
General_RadioGroup.addRadioButton(General_Interact_RB); //place radiobutton in radiogroup
General_Container.addWidget(General_RadioGroup);
//Setup Mode Elements
SetupMode_Container = new APWidgetContainer(this);
SetupMode_ConnectButton = new APButton(5, 200, 900, 100, "Start Connection");
SetupMode_DisconnectButton = new APButton(5, 300, 900, 100, "Stop Connection");
SetupMode_Container.addWidget(SetupMode_ConnectButton);
SetupMode_Container.addWidget(SetupMode_DisconnectButton);
//Interact Mode Elements
InteractMode_Container = new APWidgetContainer(this);
InteractMode_SendButton = new APButton(5, 500, 900, 100, "SendToBT");
InteractMode_TypeTB = new APEditText(5, 150, 350, 100);
InteractMode_ExposuresTB = new APEditText(5, 250, 350, 100);
InteractMode_DelayTB = new APEditText(5, 350, 350, 100);
InteractMode_Container.addWidget(InteractMode_SendButton);
InteractMode_Container.addWidget(InteractMode_TypeTB);
InteractMode_Container.addWidget(InteractMode_ExposuresTB);
InteractMode_Container.addWidget(InteractMode_DelayTB);
//Finishing Touches
General_Setup_RB.setChecked(true); //Setup mode is selected by default
SetupMode_Container.hide();
InteractMode_Container.hide();
}
void draw(){
if(General_Setup_RB.isChecked()){
background(4, 49, 50);
SetupMode_Container.show();
InteractMode_Container.hide();
}
else if(General_Interact_RB.isChecked()){
background(50, 4, 48);
//creates text on screen
textSize(32);
text("Mode: " + InteractMode_TypeTB.getText(), 370, 200);
textSize(32);
text("Exposures: " + InteractMode_ExposuresTB.getText(), 370, 300);
textSize(32);
text("Delay: " + InteractMode_DelayTB.getText(), 370, 400);
SetupMode_Container.hide();
InteractMode_Container.show();
}
}
void onClickWidget(APWidget widget){
if(widget == SetupMode_ConnectButton){
bt.start(); //start listening for BT connections
if (bt.getDiscoveredDeviceNames().size() > 0) //If we have not discovered any devices, try prior paired devices
klist = new KetaiList(this, bt.getDiscoveredDeviceNames());
else if (bt.getPairedDeviceNames().size() > 0)
klist = new KetaiList(this, bt.getPairedDeviceNames());
}
if(widget == SetupMode_ConnectButton){
bt.stop(); //start listening for BT connections
}
if (widget == InteractMode_SendButton){
String m = InteractMode_TypeTB.getText() + ',' + InteractMode_ExposuresTB.getText() + ',' + InteractMode_DelayTB.getText() + '.'; //translates the selection by the user to
print(m.getBytes()+ " , "+ m);
bt.broadcast(m.getBytes()) ;
}
}
void onKetaiListSelection(KetaiList klist) { //Recives your selection
String selection = klist.getSelection();
text(str(bt.connectToDeviceByName(selection)),10,100);
//dispose of list for now
klist = null;
}
void onBluetoothDataEvent(String who, byte[] data) { //Call back method to manage data received
if (isConfiguring)
return;
//KetaiOSCMessage is the same as OscMessage
// but allows construction by byte array
KetaiOSCMessage m = new KetaiOSCMessage(data);
if (m.isValid())
{
if (m.checkAddrPattern("/remoteMouse/"))
{
if (m.checkTypetag("ii"))
{
remoteMouse.x = m.get(0).intValue();
remoteMouse.y = m.get(1).intValue();
}
}
}
}
String getBluetoothInformation(){
String btInfo = "Server Running: ";
btInfo += bt.isStarted() + "\n";
btInfo += "Discovering: " + bt.isDiscovering() + "\n";
btInfo += "Device Discoverable: "+bt.isDiscoverable() + "\n";
btInfo += "\nConnected Devices: \n";
ArrayList<String> devices = bt.getConnectedDeviceNames();
for (String device: devices)
{
btInfo+= device+"\n";
}
return btInfo;
}
Let me know if you ever use this!
This was a horrible (!) experience. I ran in to a slew of errors from the “Android Mode” menu not showing up, to having to adjust my PATH variable. Hopefully this guide helps somebody. Most of this is taken from this guide from processing, but a lot of the errors I ran into I resolved using various forums.
First things first, download the Android SDK for an existing API.
From there, you need to install the SDK as well as some pretty specific packages using the SDK manager. [Android SDK Platform-tools], [Android 2.3.3 (API 10) > SDK Platform] and [Google USB Driver under Extras]. My setup worked once I hit “deselect all”. Note the location of the SDK.
The install of Processing is very simple. Please note that the “modes” folder inside the folder is NOT the folder you manually install modes in. Please note the location of your sketchbook folder from the preferences inside of processing.
Next, you need to download and install Java’s JDK here.
So this is where stuff started to go south. For some unknown reason, when I installed processing, “Android Mode” didn’t appear in the modes box in the top right corner.
I had to manually install AndroidMode. To do that, you must download and uncompress it into the modes folder IN your sketchbook folder.
Once you can see “Android Mode” you will need to locate the SDK.
Once I got this working, upon compiling a demo app with my phone connected resulted in errors!
BUILD FAILED C:\ADT\adt-bundle-windows-x86_64-20131030\sdk\tools\ant\build.xml:720: The following error occurred while executing this line: C:\ADT\adt-bundle-windows-x86_64-20131030\sdk\tools\ant\build.xml:734: Error running javac.exe compiler Total time: 1 second
You must edit the “Path” variable by adding a semicolon with the location of your JDK’s bin folder.
And there you go. Everything should be working now.
In order to connect your phone and upload your apps to it, you need to set your phone to developer mode, which is very simple. Look here for instructions.
I was recently accepted into a beta test for MIT dealing with a prototype Arduino board and their website. I’ll create a final post showcasing the completed project, but for step by step updates check out their website here, and my personal project page here. Now on to the tutorial.
I always reset my module after I dust it off for use, jussttt in case:
Because I know I’ll need to do this again, I’ve decided to take the time writing a post explaining how to get communication going between an Arduino and a PC using serial over bluetooth in windows 8.
First thing’s first, connect to your device, as stated in the title, I’m using a BlueSMiRF Silver from Sparkfun.
Pairing is very easy. From there, upload the following code to your Arduino and connect your board as dictated by the code.
#include <SoftwareSerial.h>
SoftwareSerial mySerial(10, 11); // RX, TX
void setup() {
Serial.begin(115200);
Serial.println("Send Hardware");
mySerial.begin(115200);
mySerial.println("Send Bluetooth");
}
void loop(){
if (mySerial.available())
Serial.write(mySerial.read());
if (Serial.available())
mySerial.write(Serial.read());
}
NOTE: IN ORDER TO USE DIFFERENT SERIAL SPEEDS, YOU WILL NEED TO MANUALLY CHANGE THE BAUD RATE USING THE DEBUG MODE IN THE BLUESMIRF.
https://learn.sparkfun.com/tutorials/using-the-bluesmirf
Then open your device manager and see how the bluetooth configuration went and how the ports were assigned:
For some reason, the lower COM port number is the correct one, I have no idea why. I’ll be using Putty to connect to the bluetooth COM port, the config is very simple:
<a href=”http://imgur.com/lXBc69L”><img src=”http://i.imgur.com/lXBc69L.png?1″ title=”Hosted by imgur.com” /></a>
From there, start typing in either console and it should all work!
Thanks for reading!
I bought a wire rack from walmart and put the PiPlanter back inside my house. Hopefully the plants will live longer than they did last year so while I’m at college I can continue to develop on this model. Images below.
If I haven’t mentioned it already, https://twitter.com/piplanter_bot IS the new twitter account for PiPlanter. Like last time, I’m using the tweepy library for python to handle all things twitter for the project. What I’m NOT using this time is Flickr. From a design point of view, it wasn’t worth it. It was too complicated and had too many things that could go wrong for me to continue using it. Twitter is more than capable of hosting images, and tweepy has a very simple method of passing these images to twitter. Recently I moved the whole setup indoors and mounted it all onto a shelf seen here and it came with a set of strange problems.
Long story short, what I think happened was that since I moved them to a different location, the complexity of the images increased, causing an increase in the size of the images themselves. A broken pipe error implies that the entirety of the package sent to twitter wasn’t sent, causing the tweet not to go through. I first started to suspect this problem after seeing this:
The graphs were going through just fine, but images were seeming to have a hard time. You can’t tell from this photo, but those tweets are hours apart as opposed to the 20 minutes they are supposed to be. Once I started having this problem, I bit the bullet and integrated logging into my project which produced this log:
[08-12-2014_11-21-20-PM] Debug: MySQL Tables Updated Simple [08-12-2014_11-21-20-PM] Debug: Debug Update: P_MST0: 87.10938, P_MST1: 89.64844, A_TMP0: 69.03711, A_LDR0: 70.99609 [08-12-2014_11-21-26-PM] Debug: Image Captured, High Quality = False, Image: /home/pi/PiPlanter2/images/dailys/CurrentImageDirectory_08_11_2014__06_58_32PM/0098.jpg [08-12-2014_11-21-26-PM] Debug: Attempt [0] To Tweet: Ambient Light: 70.6%, Ambient Temp: 69.0DF, Average Plant Mst: 88.5% https://esologic.com/?page_id=1042 , image = True [08-12-2014_11-21-57-PM] Debug: Tweet Failed, Retrying [08-12-2014_11-21-57-PM] Debug: Twitter Error: Failed to send request: [Errno 32] Broken pipe [08-12-2014_11-22-12-PM] Debug: Attempt [1] To Tweet: Ambient Light: 70.6%, Ambient Temp: 69.0DF, Average Plant Mst: 88.5% https://esologic.com/?page_id=1042 , image = True [08-12-2014_11-22-43-PM] Debug: Tweet Failed, Retrying [08-12-2014_11-22-43-PM] Debug: Twitter Error: Failed to send request: [Errno 32] Broken pipe [08-12-2014_11-22-58-PM] Debug: Attempt [2] To Tweet: Ambient Light: 70.6%, Ambient Temp: 69.0DF, Average Plant Mst: 88.5% https://esologic.com/?page_id=1042 , image = True [08-12-2014_11-23-30-PM] Debug: Tweet Failed, Retrying [08-12-2014_11-23-30-PM] Debug: Twitter Error: Failed to send request: [Errno 32] Broken pipe [08-12-2014_11-23-45-PM] Debug: Attempt [3] To Tweet: Ambient Light: 70.6%, Ambient Temp: 69.0DF, Average Plant Mst: 88.5% https://esologic.com/?page_id=1042 , image = True [08-12-2014_11-24-16-PM] Debug: Tweet Failed, Retrying [08-12-2014_11-24-16-PM] Debug: Twitter Error: Failed to send request: [Errno 32] Broken pipe [08-12-2014_11-24-31-PM] Debug: Attempt [4] To Tweet: Ambient Light: 70.6%, Ambient Temp: 69.0DF, Average Plant Mst: 88.5% https://esologic.com/?page_id=1042 , image = True [08-12-2014_11-25-03-PM] Debug: Tweet Failed, Retrying [08-12-2014_11-25-03-PM] Debug: Twitter Error: Failed to send request: [Errno 32] Broken pipe [08-12-2014_11-25-18-PM] Debug: Attempt [5] To Tweet: Ambient Light: 70.6%, Ambient Temp: 69.0DF, Average Plant Mst: 88.5% https://esologic.com/?page_id=1042 , image = True [08-12-2014_11-25-49-PM] Debug: Tweet Failed, Retrying [08-12-2014_11-25-49-PM] Debug: Twitter Error: Failed to send request: [Errno 32] Broken pipe [08-12-2014_11-26-04-PM] Debug: Attempt [6] To Tweet: Ambient Light: 70.6%, Ambient Temp: 69.0DF, Average Plant Mst: 88.5% https://esologic.com/?page_id=1042 , image = True [08-12-2014_11-26-36-PM] Debug: Tweet Failed, Retrying [08-12-2014_11-26-36-PM] Debug: Twitter Error: Failed to send request: [Errno 32] Broken pipe [08-12-2014_11-26-51-PM] Debug: Attempt [7] To Tweet: Ambient Light: 70.6%, Ambient Temp: 69.0DF, Average Plant Mst: 88.5% https://esologic.com/?page_id=1042 , image = True [08-12-2014_11-27-22-PM] Debug: Tweet Failed, Retrying [08-12-2014_11-27-22-PM] Debug: Twitter Error: Failed to send request: [Errno 32] Broken pipe [08-12-2014_11-27-37-PM] Debug: Attempt [8] To Tweet: Ambient Light: 70.6%, Ambient Temp: 69.0DF, Average Plant Mst: 88.5% https://esologic.com/?page_id=1042 , image = True [08-12-2014_11-29-07-PM] Debug: Tweet Failed, Retrying [08-12-2014_11-29-07-PM] Debug: Twitter Error: Failed to send request: The write operation timed out [08-12-2014_11-29-22-PM] Debug: Attempt [9] To Tweet: Ambient Light: 70.6%, Ambient Temp: 69.0DF, Average Plant Mst: 88.5% https://esologic.com/?page_id=1042 , image = True [08-12-2014_11-29-54-PM] Debug: Tweet Failed, Retrying [08-12-2014_11-29-54-PM] Debug: Twitter Error: Failed to send request: [Errno 32] Broken pipe [08-12-2014_11-30-09-PM] Debug: Tweet Was a Failure
Hours and hours of failed tweets due to “[Errno 32] Broken pipe”. I tried a lot of things, I figured out that it was the size of the images after seeing this:
Photos that were simple in nature had no problem being sent. After scaling the image size down, I’ve had absolutely no problem sending tweets.
If you are tweeting images with tweepy in python and getting intermediate Broken pipe errors, decrease the size of your image.
Thanks for reading.
I’m almost done with a very stable version of the Python code running the PiPlanter. There are many specific differences between this version of the python code and the version I wrote and implemented last summer, but the main one is that I tried to write functions for pretty much every task I wanted to do, and made each routine much more modular instead of one long line after line block to do each day. This took significantly longer to do (thus the lack of updates, sorry) but is much more expandable going forward. Below is the new version of the code, but by no means am I an expert programmer. The following code seems to work very well for what I want it to do.
import MySQLdb
from datetime import datetime
import time
from time import sleep
import os
import sys
import spidev
import RPi.GPIO as GPIO
import tweepy
import logging
logging.basicConfig()
from apscheduler.scheduler import Scheduler
import subprocess
def ConsoleDebug(input):
debug = '[' + datetime.now().strftime("%m-%d-%Y_%I-%M-%S-%p") + '] Debug: ' + input
print debug
file = open(str(os.getcwd()) + "/log.txt", "a")
file.write(debug + "\n")
file.close()
def FirstTimeSetup():
global cycle
ConsoleDebug('---------------- NEW INSTANCE OF PIPLANTER ----------------')
MySQL_Commands = {1 : 'CREATE DATABASE IF NOT EXISTS PiPlanter_DB', 2: "GRANT ALL ON `PiPlanter_DB`.* TO 'piplanter'@'localhost' IDENTIFIED BY 'password'", 3: 'USE PiPlanter_DB' }
for i in MySQL_Commands.itervalues():
ConsoleDebug('MYSQL COMMAND: ' + i)
cursor.execute(i)
MySQLTableSetup(False,'Daily',True)
VisualLocationSetup(True,'dontcare')
ConsoleDebug('Setup Complete')
cycle = 0
def MySQLTableSetup(full,kind,first):
global MySQL_Tables
now = datetime.now().strftime("%m_%d_%Y__%I_%M_%S%p")
if first == True:
MySQL_Tables = { 'MySQLTable_Daily' : 'DailyTable' + now, 'MySQLTable_Weekly' : 'WeeklyTable' + now, 'MySQLTable_Monthly' : 'MonthlyTable' + now}
if full == False:
CreateTables = {0: "CREATE TABLE " + MySQL_Tables['MySQLTable_Daily'] + "(Sample_Number INT NOT NULL AUTO_INCREMENT PRIMARY KEY,Time VARCHAR(100),P_MST0 VARCHAR(100),P_MST1 VARCHAR(100),A_TMP0 VARCHAR(100),A_LDR0 VARCHAR(100))", 1 : "CREATE TABLE " + MySQL_Tables['MySQLTable_Weekly'] + "(Sample_Number INT NOT NULL AUTO_INCREMENT PRIMARY KEY,Time VARCHAR(100),P_MST0 VARCHAR(100),P_MST1 VARCHAR(100),A_TMP0 VARCHAR(100),A_LDR0 VARCHAR(100))" , 2 : "CREATE TABLE " + MySQL_Tables['MySQLTable_Monthly'] + "(Sample_Number INT NOT NULL AUTO_INCREMENT PRIMARY KEY,Time VARCHAR(100),P_MST0 VARCHAR(100),P_MST1 VARCHAR(100),A_TMP0 VARCHAR(100),A_LDR0 VARCHAR(100))"}
for i in CreateTables.itervalues():
ConsoleDebug('MYSQL COMMAND: ' + i)
cursor.execute(i)
if full == True:
CreateTables = {0: "CREATE TABLE " + MySQL_Tables['MySQLTable_Daily'] + "(Sample_Number INT NOT NULL AUTO_INCREMENT PRIMARY KEY,Time VARCHAR(100),P_TMP0 VARCHAR(100),P_MST0 VARCHAR(100),P_TMP1 VARCHAR(100),P_MST1 VARCHAR(100),P_TMP2 VARCHAR(100),P_MST2 VARCHAR(100),P_TMP3 VARCHAR(100),P_MST3 VARCHAR(100),A_TMP0 VARCHAR(100),A_LDR0 VARCHAR(100),A_LDR1 VARCHAR(100),A_MST0 VARCHAR(100))", 1:"CREATE TABLE " + MySQL_Tables['MySQLTable_Weekly'] + "(Sample_Number INT NOT NULL AUTO_INCREMENT PRIMARY KEY,Time VARCHAR(100),P_TMP0 VARCHAR(100),P_MST0 VARCHAR(100),P_TMP1 VARCHAR(100),P_MST1 VARCHAR(100),P_TMP2 VARCHAR(100),P_MST2 VARCHAR(100),P_TMP3 VARCHAR(100),P_MST3 VARCHAR(100),A_TMP0 VARCHAR(100),A_LDR0 VARCHAR(100),A_LDR1 VARCHAR(100),A_MST0 VARCHAR(100))" , 2:"CREATE TABLE " + MySQL_Tables['MySQLTable_Monthly'] + "(Sample_Number INT NOT NULL AUTO_INCREMENT PRIMARY KEY,Time VARCHAR(100),P_TMP0 VARCHAR(100),P_MST0 VARCHAR(100),P_TMP1 VARCHAR(100),P_MST1 VARCHAR(100),P_TMP2 VARCHAR(100),P_MST2 VARCHAR(100),P_TMP3 VARCHAR(100),P_MST3 VARCHAR(100),A_TMP0 VARCHAR(100),A_LDR0 VARCHAR(100),A_LDR1 VARCHAR(100),A_MST0 VARCHAR(100))" }
for i in CreateTables.itervalues():
ConsoleDebug('MYSQL COMMAND: ' + i)
cursor.execute(i)
elif first == False:
if kind == 'Daily':
ConsoleDebug('Daily Database Name Has Been Updated')
MySQL_Tables['MySQLTable_Daily'] = 'DailyTable_' + now
ConsoleDebug(MySQL_Tables['MySQLTable_Daily'])
if full == False:
CreateTable = "CREATE TABLE " + MySQL_Tables['MySQLTable_Daily'] + "(Sample_Number INT NOT NULL AUTO_INCREMENT PRIMARY KEY,Time VARCHAR(100),P_MST0 VARCHAR(100),P_MST1 VARCHAR(100),A_TMP0 VARCHAR(100),A_LDR0 VARCHAR(100))"
elif full == True:
CreateTable = "CREATE TABLE " + MySQL_Tables['MySQLTable_Daily'] + "(Sample_Number INT NOT NULL AUTO_INCREMENT PRIMARY KEY,Time VARCHAR(100),P_TMP0 VARCHAR(100),P_MST0 VARCHAR(100),P_TMP1 VARCHAR(100),P_MST1 VARCHAR(100),P_TMP2 VARCHAR(100),P_MST2 VARCHAR(100),P_TMP3 VARCHAR(100),P_MST3 VARCHAR(100),A_TMP0 VARCHAR(100),A_LDR0 VARCHAR(100),A_LDR1 VARCHAR(100),A_MST0 VARCHAR(100))"
elif kind == 'Weekly':
ConsoleDebug('Daily Database Name Has Been Updated')
MySQL_Tables['MySQLTable_Weekly'] = 'WeeklyTable_' + now
ConsoleDebug(MySQL_Tables['MySQLTable_Weekly'])
if full == False:
CreateTable = "CREATE TABLE " + MySQL_Tables['MySQLTable_Weekly'] + "(Sample_Number INT NOT NULL AUTO_INCREMENT PRIMARY KEY,Time VARCHAR(100),P_MST0 VARCHAR(100),P_MST1 VARCHAR(100),A_TMP0 VARCHAR(100),A_LDR0 VARCHAR(100))"
elif full == True:
CreateTable = "CREATE TABLE " + MySQL_Tables['MySQLTable_Weekly'] + "(Sample_Number INT NOT NULL AUTO_INCREMENT PRIMARY KEY,Time VARCHAR(100),P_TMP0 VARCHAR(100),P_MST0 VARCHAR(100),P_TMP1 VARCHAR(100),P_MST1 VARCHAR(100),P_TMP2 VARCHAR(100),P_MST2 VARCHAR(100),P_TMP3 VARCHAR(100),P_MST3 VARCHAR(100),A_TMP0 VARCHAR(100),A_LDR0 VARCHAR(100),A_LDR1 VARCHAR(100),A_MST0 VARCHAR(100))"
elif kind == 'Monthly':
ConsoleDebug('Daily Database Name Has Been Updated')
MySQL_Tables['MySQLTable_Monthly'] = 'MonthlyTable_' + now
ConsoleDebug(MySQL_Tables['MySQLTable_Monthly'])
if full == False:
CreateTable = "CREATE TABLE " + MySQL_Tables['MySQLTable_Monthly'] + "(Sample_Number INT NOT NULL AUTO_INCREMENT PRIMARY KEY,Time VARCHAR(100),P_MST0 VARCHAR(100),P_MST1 VARCHAR(100),A_TMP0 VARCHAR(100),A_LDR0 VARCHAR(100))"
elif full == True:
CreateTable = "CREATE TABLE " + MySQL_Tables['MySQLTable_Monthly'] + "(Sample_Number INT NOT NULL AUTO_INCREMENT PRIMARY KEY,Time VARCHAR(100),P_TMP0 VARCHAR(100),P_MST0 VARCHAR(100),P_TMP1 VARCHAR(100),P_MST1 VARCHAR(100),P_TMP2 VARCHAR(100),P_MST2 VARCHAR(100),P_TMP3 VARCHAR(100),P_MST3 VARCHAR(100),A_TMP0 VARCHAR(100),A_LDR0 VARCHAR(100),A_LDR1 VARCHAR(100),A_MST0 VARCHAR(100))"
ConsoleDebug('MYSQL: ' + CreateTable)
cursor.execute(CreateTable)
ConsoleDebug('Current Daily: ' + MySQL_Tables['MySQLTable_Daily'])
ConsoleDebug('Current Weekly: ' + MySQL_Tables['MySQLTable_Weekly'])
ConsoleDebug('Current Monthly: ' + MySQL_Tables['MySQLTable_Monthly'])
def VisualLocationSetup(first,kind):
global VisualLocation
now = datetime.now().strftime("%m_%d_%Y__%I_%M_%S%p")
runninglocation = str(os.getcwd())
if first == True:
ConsoleDebug('Creating Video Directory')
if not os.path.exists(runninglocation + '/videos/'):
os.makedirs(runninglocation + '/videos/')
ConsoleDebug('Video Directory Created')
else:
ConsoleDebug('Video Directory Already Exists')
ConsoleDebug('Creating Daily Video Directory')
if not os.path.exists(runninglocation + '/videos/dailys/'):
os.makedirs(runninglocation + '/videos/dailys/')
else:
ConsoleDebug('Daily Video Directory Already Exists')
ConsoleDebug('Creating Image Directory')
if not os.path.exists(runninglocation + '/images/'):
os.makedirs(runninglocation + '/images/')
else:
ConsoleDebug('Image Directory Already Exists')
ConsoleDebug('Creating Daily Image Directory')
if not os.path.exists(runninglocation + '/images/dailys/'):
os.makedirs(runninglocation + '/images/dailys/')
else:
ConsoleDebug('Daily Image Directory Already Exists')
ConsoleDebug('Creating Graph Directory')
if not os.path.exists(runninglocation + '/graphs/'):
os.makedirs(runninglocation + '/graphs/')
else:
ConsoleDebug('Graph Directory Already Exists')
ConsoleDebug('Updating All Current Visual Directories')
VisualLocation = {'CurrentImageDirectory' : runninglocation + '/images/dailys/' + 'CurrentImageDirectory_' + now + '/' , 'CurrentVideoDirectory' : runninglocation + '/videos/dailys/' + 'CurrentVideoDirectory_' + now + '/' , 'CurrentGraphDirectory' : runninglocation + '/graphs/' + 'CurrentGraphDirectory_' + now + '/' }
for i in VisualLocation.itervalues():
ConsoleDebug('Making Directory: ' + i)
os.makedirs(i)
if first == False:
ConsoleDebug('Updating Location Of ' + kind + ' Directory')
if kind == 'Image':
VisualLocation['CurrentImageDirectory'] = runninglocation + '/images/dailys/' + 'CurrentImageDirectory_' + now + '/'
ConsoleDebug('Making Directory: ' + VisualLocation['CurrentImageDirectory'])
os.makedirs(VisualLocation['CurrentImageDirectory'])
elif kind == 'Video':
VisualLocation['CurrentVideoDirectory'] = runninglocation + '/videos/dailys/' + 'CurrentVideoDirectory_' + now + '/'
ConsoleDebug('Making Directory: ' + VisualLocation['CurrentVideoDirectory'])
os.makedirs(VisualLocation['CurrentVideoDirectory'])
elif kind == 'Graph':
VisualLocation['CurrentGraphDirectory'] = runninglocation + '/graphs/' + 'CurrentGraphDirectory_' + now + '/'
ConsoleDebug('Making Directory: ' + VisualLocation['CurrentGraphDirectory'])
os.makedirs(VisualLocation['CurrentGraphDirectory'])
ConsoleDebug('Current Image Directory' + VisualLocation['CurrentImageDirectory'])
ConsoleDebug('Current Video Directory' + VisualLocation['CurrentVideoDirectory'])
ConsoleDebug('Current Graph Directory' + VisualLocation['CurrentGraphDirectory'])
return 0
#this function can be used to find out the ADC value on ADC 0
def ReadADC0(adcnum_0):
if adcnum_0 > 7 or adcnum_0 < 0:
return -1
r_0 = spi_0.xfer2([1, 8 + adcnum_0 << 4, 0])
adcout_0 = ((r_0[1] & 3) << 8) + r_0[2]
return adcout_0
#this function can be used to find out the ADC value on ADC 1
def ReadADC1(adcnum_1):
if adcnum_1 > 7 or adcnum_1 < 0:
return -1
r_1 = spi_1.xfer2([1, 8 + adcnum_1 << 4, 0])
adcout_1 = ((r_1[1] & 3) << 8) + r_1[2]
return adcout_1
#this function converts a given value from the ADC and turns it into usable data
def ConvertADC(adcinput,unit):
millivolts = adcinput*(3300.0/1024.0) #converts the ADC value to milivolts
temp_c = ((millivolts - 100.0)/10)-40.0
percent = (adcinput/1024.0)*100
if unit == 'c' : #used for a temperature sensor to return Celsius
return temp_c
elif unit == 'f' : #used for a temperature sensor to return Fahrenheit
temp_f = (temp_c * 9.0 / 5.0) + 32
return temp_f
elif unit == 'mV':
return millivolts
elif unit == '%':
return percent
else:
print "ConvertADC input error"
return 0
return 0
#returns a usable numerical value from the ADC
def PollSensor(sensor,unit,precision,samples):
GPIO.output(pins['MST_Enable'], True)
if PiPlanterFull == True:
#Full PiPlanter
sensors = {\
'P_TMP0' : ConvertADC(ReadADC0(0),unit),\
'P_MST0' : ConvertADC(ReadADC0(1),unit),\
'P_TMP1' : ConvertADC(ReadADC0(2),unit),\
'P_MST1' : ConvertADC(ReadADC0(3),unit),\
'P_TMP2' : ConvertADC(ReadADC0(4),unit),\
'P_MST2' : ConvertADC(ReadADC0(5),unit),\
'P_TMP3' : ConvertADC(ReadADC0(6),unit),\
'P_MST3' : ConvertADC(ReadADC0(7),unit),\
'A_TMP0' : ConvertADC(ReadADC1(0),unit),\
'A_LDR0' : ConvertADC(ReadADC1(1),unit),\
'A_LDR1' : ConvertADC(ReadADC1(2),unit),\
'A_MST0' : ConvertADC(ReadADC1(3),unit)}
else:
#Simple PiPlanter
sensors = {\
'P_MST0' : ConvertADC(ReadADC0(0),unit),\
'P_MST1' : ConvertADC(ReadADC0(1),unit),\
'A_TMP0' : ConvertADC(ReadADC0(2),unit),\
'A_LDR0' : ConvertADC(ReadADC0(3),unit)}
outputsum = 0
for x in range(0,samples): #An averaging algorithm that creates a more precise reading
outputsum = outputsum + sensors[sensor]
output = round(outputsum/samples, precision)
GPIO.output(pins['MST_Enable'], False)
return output
#samples all sensors, outputs different formats of the data to be used in other places in the program
def SampleAllSensors(sensor_precision,sensor_samples,form,Full):
global MySQL_Tables
if Full == True:
#Full PiPlanter
current_sensors = {\
'P_TMP0' : PollSensor('P_TMP0' , 'f', sensor_precision, sensor_samples),\
'P_MST0' : PollSensor('P_MST0' , '%', sensor_precision, sensor_samples),\
'P_TMP1' : PollSensor('P_TMP1' , 'f', sensor_precision, sensor_samples),\
'P_MST1' : PollSensor('P_MST1' , '%', sensor_precision, sensor_samples),\
'P_TMP2' : PollSensor('P_TMP2' , 'f', sensor_precision, sensor_samples),\
'P_MST2' : PollSensor('P_MST2' , '%', sensor_precision, sensor_samples),\
'P_TMP3' : PollSensor('P_TMP3' , 'f', sensor_precision, sensor_samples),\
'P_MST3' : PollSensor('P_MST3' , '%', sensor_precision, sensor_samples),\
'A_TMP0' : PollSensor('A_TMP0' , 'f', sensor_precision, sensor_samples),\
'A_LDR0' : PollSensor('A_LDR0' , '%', sensor_precision, sensor_samples),\
'A_LDR1' : PollSensor('A_LDR1' , '%', sensor_precision, sensor_samples),\
'A_MST0' : PollSensor('A_MST0' , '%', sensor_precision, sensor_samples)}
else:
#Simple PiPlanter
current_sensors = {\
'P_MST0' : PollSensor('P_MST0' , '%', sensor_precision, sensor_samples),\
'P_MST1' : PollSensor('P_MST1' , '%', sensor_precision, sensor_samples),\
'A_TMP0' : PollSensor('A_TMP0' , 'f', sensor_precision, sensor_samples),\
'A_LDR0' : PollSensor('A_LDR0' , '%', sensor_precision, sensor_samples)}
if form == 'MySQL':
if Full == True:
#Full PiPlanter
cursor.execute("INSERT INTO " + MySQL_Tables['MySQLTable_Daily'] + "(Time, P_TMP0, P_MST0, P_TMP1, P_MST1, P_TMP2, P_MST2, P_TMP3, P_MST3, A_TMP0, A_LDR0, A_LDR1, A_MST0)" + " VALUES(NOW()" + "," + str(current_sensors['P_TMP0']) + "," + str(current_sensors['P_MST0']) + "," + str(current_sensors['P_TMP1']) + "," + str(current_sensors['P_MST1']) + "," + str(current_sensors['P_TMP2']) + "," + str(current_sensors['P_MST2']) + "," + str(current_sensors['P_TMP3']) + "," + str(current_sensors['P_MST3']) + "," + str(current_sensors['A_TMP0']) + "," + str(current_sensors['A_LDR0']) + "," + str(current_sensors['A_LDR1']) + "," + str(current_sensors['A_MST0']) + ")" )
user.commit()
cursor.execute("INSERT INTO " + MySQL_Tables['MySQLTable_Weekly'] + "(Time, P_TMP0, P_MST0, P_TMP1, P_MST1, P_TMP2, P_MST2, P_TMP3, P_MST3, A_TMP0, A_LDR0, A_LDR1, A_MST0)" + " VALUES(NOW()" + "," + str(current_sensors['P_TMP0']) + "," + str(current_sensors['P_MST0']) + "," + str(current_sensors['P_TMP1']) + "," + str(current_sensors['P_MST1']) + "," + str(current_sensors['P_TMP2']) + "," + str(current_sensors['P_MST2']) + "," + str(current_sensors['P_TMP3']) + "," + str(current_sensors['P_MST3']) + "," + str(current_sensors['A_TMP0']) + "," + str(current_sensors['A_LDR0']) + "," + str(current_sensors['A_LDR1']) + "," + str(current_sensors['A_MST0']) + ")" )
user.commit()
cursor.execute("INSERT INTO " + MySQL_Tables['MySQLTable_Monthly'] + "(Time, P_TMP0, P_MST0, P_TMP1, P_MST1, P_TMP2, P_MST2, P_TMP3, P_MST3, A_TMP0, A_LDR0, A_LDR1, A_MST0)" + " VALUES(NOW()" + "," + str(current_sensors['P_TMP0']) + "," + str(current_sensors['P_MST0']) + "," + str(current_sensors['P_TMP1']) + "," + str(current_sensors['P_MST1']) + "," + str(current_sensors['P_TMP2']) + "," + str(current_sensors['P_MST2']) + "," + str(current_sensors['P_TMP3']) + "," + str(current_sensors['P_MST3']) + "," + str(current_sensors['A_TMP0']) + "," + str(current_sensors['A_LDR0']) + "," + str(current_sensors['A_LDR1']) + "," + str(current_sensors['A_MST0']) + ")" )
user.commit()
ConsoleDebug('MySQL Tables Updated Full')
output = "INSERT INTO " + MySQL_Tables['MySQLTable_Monthly'] + "(Time, P_TMP0, P_MST0, P_TMP1, P_MST1, P_TMP2, P_MST2, P_TMP3, P_MST3, A_TMP0, A_LDR0, A_LDR1, A_MST0)" + " VALUES(NOW()" + "," + str(current_sensors['P_TMP0']) + "," + str(current_sensors['P_MST0']) + "," + str(current_sensors['P_TMP1']) + "," + str(current_sensors['P_MST1']) + "," + str(current_sensors['P_TMP2']) + "," + str(current_sensors['P_MST2']) + "," + str(current_sensors['P_TMP3']) + "," + str(current_sensors['P_MST3']) + "," + str(current_sensors['A_TMP0']) + "," + str(current_sensors['A_LDR0']) + "," + str(current_sensors['A_LDR1']) + "," + str(current_sensors['A_MST0']) + ")"
else:
#Simple PiPlanter
cursor.execute("INSERT INTO " + MySQL_Tables['MySQLTable_Daily'] + "(Time, P_MST0, P_MST1, A_TMP0, A_LDR0)" + " VALUES(NOW()" + "," + str(current_sensors['P_MST0']) + "," + str(current_sensors['P_MST1']) + "," + str(current_sensors['A_TMP0']) + "," + str(current_sensors['A_LDR0']) + ")" )
user.commit()
cursor.execute("INSERT INTO " + MySQL_Tables['MySQLTable_Weekly'] + "(Time, P_MST0, P_MST1, A_TMP0, A_LDR0)" + " VALUES(NOW()" + "," + str(current_sensors['P_MST0']) + "," + str(current_sensors['P_MST1']) + "," + str(current_sensors['A_TMP0']) + "," + str(current_sensors['A_LDR0']) + ")" )
user.commit()
cursor.execute("INSERT INTO " + MySQL_Tables['MySQLTable_Monthly'] + "(Time, P_MST0, P_MST1, A_TMP0, A_LDR0)" + " VALUES(NOW()" + "," + str(current_sensors['P_MST0']) + "," + str(current_sensors['P_MST1']) + "," + str(current_sensors['A_TMP0']) + "," + str(current_sensors['A_LDR0']) + ")" )
user.commit()
ConsoleDebug('MySQL Tables Updated Simple')
output = "INSERT INTO " + MySQL_Tables['MySQLTable_Daily'] + "(Time, P_MST0, P_MST1, A_TMP0, A_LDR0)" + " VALUES(NOW()" + "," + str(current_sensors['P_MST0']) + "," + str(current_sensors['P_MST1']) + "," + str(current_sensors['A_TMP0']) + "," + str(current_sensors['A_LDR0']) + ")"
elif form == 'Console':
if Full == True:
#Full PiPlanter
output = 'Debug Update:' + ' P_TMP0: ' + str(str(current_sensors['P_TMP0'])) + ',' + ' P_MST0: ' + str(str(current_sensors['P_MST0'])) + ',' + ' P_TMP1: ' + str(str(current_sensors['P_TMP1'])) + ',' + ' P_MST1: ' + str(str(current_sensors['P_MST1'])) + ','+ ' P_TMP2: ' + str(str(current_sensors['P_TMP2'])) + ','+ ' P_MST2: ' + str(str(current_sensors['P_MST2'])) + ','+ ' P_TMP3: ' + str(str(current_sensors['P_TMP3'])) + ','+ ' P_MST3: ' + str(str(current_sensors['P_MST3'])) + ',' + ' A_TMP0: ' + str(str(current_sensors['A_TMP0'])) + ',' + ' A_LDR0: ' + str(str(current_sensors['A_LDR0'])) + ','+ ' A_LDR1: ' + str(str(current_sensors['A_LDR1'])) + ','+ ' A_MST0: ' + str(str(current_sensors['A_MST0']))
else:
#Simple PiPlanter
output = 'Debug Update:' + ' P_MST0: ' + str(str(current_sensors['P_MST0'])) + ',' + ' P_MST1: ' + str(str(current_sensors['P_MST1'])) + ',' + ' A_TMP0: ' + str(str(current_sensors['A_TMP0'])) + ',' + ' A_LDR0: ' + str(str(current_sensors['A_LDR0']))
elif form == 'Twitter':
if Full == True:
#Full PiPlanter
output = 'Ambient LDR: ' + str(round(((current_sensors['A_LDR0'] + current_sensors['A_LDR1'])/2),1) ) + '%, ' + 'Ambient Tmp: ' + str(round(current_sensors['A_TMP0'],1)) + 'DF, ' + 'Average Plant Tmp: ' + str(round( (current_sensors['P_TMP0'] + current_sensors['P_TMP1'] + current_sensors['P_TMP2'] + current_sensors['P_TMP3'] )/4, sensor_precision-2)) + 'DF, ' + 'Ambient Mst: ' + str(round(current_sensors['A_MST0'],2)) + '%, ' + 'Average Plant Mst: ' + str(round( (current_sensors['P_MST0']+current_sensors['P_MST1']+ current_sensors['P_MST2']+ current_sensors['P_MST3'] )/4 ,1)) + '%'
else:
#Simple PiPlanter
output = 'Ambient Light: ' + str(round((current_sensors['A_LDR0']),1)) + '%, ' + 'Ambient Temp: ' + str(round(current_sensors['A_TMP0'],1)) + 'DF, ' + 'Average Plant Mst: ' + str(round( (current_sensors['P_MST0']+current_sensors['P_MST1'])/2 ,1)) + '%'
else:
print "ConvertADC input SampleAllSensors"
return 0
return output
#pumps a given amount of water from a given pump
def PumpWater(pump,volume):
LPM = 4.00 #L per minute
ontime = volume*(60/LPM)
ConsoleDebug('PUMP ON')
GPIO.output(pumps[pump],True)
time.sleep(ontime)
GPIO.output(pumps[pump],False)
ConsoleDebug('PUMP OFF')
output = 'Pumped ' + str(volume) + ' L Of Water Into Plants In ' + str(ontime) + ' Seconds'
ConsoleDebug(output)
return output
def Image(dir,cycle,high_quality):
image = dir + str(cycle).zfill(4) + '.jpg'
if high_quality == False:
picture_command = 'raspistill -q 41 -o ' + image
if high_quality == True:
picture_command = 'raspistill -q 100 -o ' + image
os.system(picture_command)
ConsoleDebug('Image Captured, High Quality = ' + str(high_quality) + ', Image: ' + str(image))
return image
def RenderGraph(table,location):
ConsoleDebug('Rendering Graph')
rendercommand = 'php ' + str(os.getcwd()) + '/pChartRender_1_0_5.php ' + table + ' ' + location
ConsoleDebug('Running Command: ' + rendercommand)
proc = subprocess.Popen(rendercommand, shell=True, stdout=subprocess.PIPE)
script_response = proc.stdout.read()
ConsoleDebug('Output File: ' + script_response)
ConsoleDebug('Rendering Complete')
return script_response
def TryTweet(image, imagelocation, text):
i = 0
while i < 500:
try:
ConsoleDebug('Attempt [' + str(i) + '] To Tweet: ' + text + ' , image = ' + str(image))
if image == True:
output = api.update_with_media(imagelocation, text)
if image == False:
output = api.update_status(text)
break
except tweepy.error.TweepError as e:
ConsoleDebug('Tweet Failed, Retrying')
ConsoleDebug('Twitter Error: ' + str(e))
i = i + 1
time.sleep(15)
ConsoleDebug('Tweet Sent After ' + str(i) + ' Attempts, Details: Actual Text [ ' + str(output.text) + '] URL: https://twitter.com/piplanter_bot/status/' + str(output.id) )
def RenderVideo(infolder,outfolder):
outputfile = outfolder + str(datetime.now().strftime("%m_%d_%Y__%I_%M_%S%p")) + '_VIDEO.avi'
ConsoleDebug('Attempting To Render: ' + outputfile)
render_command = 'sudo mencoder mf://' + str(infolder) + '*.jpg -nosound -ovc lavc -lavcopts vcodec=mpeg4:aspect=16/9:vbitrate=8000000 -vf scale=1920:1080 -mf type=jpeg:fps=15 -o ' + outputfile
os.system(render_command)
ConsoleDebug('Render Complete, File: ' + outputfile)
return outputfile
def FifteenMinutes():
global cycle
SampleAllSensors(1,1000,'MySQL',False)
ConsoleDebug(SampleAllSensors(5,1000,'Console',False))
image = Image(VisualLocation['CurrentImageDirectory'],cycle,False)
tweet = SampleAllSensors(3,20,'Twitter',False) + " https://esologic.com/?page_id=1042"
TryTweet(True,image,tweet)
cycle = cycle + 1
def ThreeHours():
graphlocation = RenderGraph(MySQL_Tables['MySQLTable_Daily'],VisualLocation['CurrentGraphDirectory'])
tweet = 'Graph of day so far: Moisture % - Blue, Ambient Light % - Yellow, Temp DF - Red https://esologic.com/?page_id=1042'
TryTweet(True,graphlocation,tweet)
def Daily():
graphlocation = RenderGraph(MySQL_Tables['MySQLTable_Daily'],VisualLocation['CurrentGraphDirectory'])
MySQLTableSetup(False,'Daily',False)
tweet = 'Graph of Previous 24 Hours: Moisture % - Blue, Ambient Light % - Yellow, Temp DF - Red https://esologic.com/?page_id=1042'
TryTweet(True,graphlocation,tweet)
tweet2 = PumpWater('PUMP0',1.5)
TryTweet(False,'',tweet2)
RenderVideo(VisualLocation['CurrentImageDirectory'],VisualLocation['CurrentVideoDirectory'])
def Weekly():
graphlocation = RenderGraph(MySQL_Tables['MySQLTable_Weekly'],VisualLocation['CurrentGraphDirectory'])
tweet = 'Graph of Previous 3 Days: Moisture % - Blue, Ambient Light % - Yellow, Temp DF - Red https://esologic.com/?page_id=1042'
TryTweet(True,graphlocation,tweet)
MySQLTableSetup(False,'Daily',False)
if __name__ == '__main__':
global MySQL_Tables
global VisualLocation
consumer_key=""
consumer_secret=""
access_token=""
access_token_secret=""
auth = tweepy.OAuthHandler(consumer_key, consumer_secret)
auth.set_access_token(access_token, access_token_secret)
api = tweepy.API(auth)
GPIO.setmode(GPIO.BOARD)
pins = {'MST_Enable' : 8} #assign names to GPIO pins
for d in pins.itervalues():
GPIO.setup(d,GPIO.OUT)
pumps = {'PUMP0' : 7, 'PUMP1' : 11, 'PUMP2' : 13, 'PUMP3' : 16} #assign names to GPIO pins
for k in pumps.itervalues():
GPIO.setup(k,GPIO.OUT)
#first ADC setup on SPI port 1
spi_1 = spidev.SpiDev()
spi_1.open(0, 1)
#first ADC setup on SPI port 0
spi_0 = spidev.SpiDev()
spi_0.open(0, 0)
PiPlanterFull = False
user = MySQLdb.connect(host="localhost",user="root",passwd="")
cursor = user.cursor()
scheduler = Scheduler(standalone=True)
scheduler.add_interval_job(FifteenMinutes, minutes = 15)
scheduler.add_interval_job(ThreeHours, hours = 3)
scheduler.add_interval_job(Daily, days=1)
scheduler.add_interval_job(Weekly, days=3)
try:
FirstTimeSetup()
PumpWater('PUMP0',3)
scheduler.start()
except (KeyboardInterrupt, SystemExit):
pass
Note the distinct lack of comments. I will put out a much more polished version of the code when it’s done. Before I move onto things like a web UI etc, I would like to do a few more things with this standalone version. The above version renders videos into time lapses, I would like to be able to upload those videos somewhere, hopefully youtube. I would also like to be able to email the log file to the user daily, which should be easier than uploading videos to youtube.
The script that renders the MySQL data into a graph is the following, it on the other hand has not changed much at all since last year and is still the best method to render graphs like I want to:
<?php
/* Include all the classes */
include("/srv/www/lib/pChart/class/pData.class.php");
include("/srv/www/lib/pChart/class/pDraw.class.php");
include("/srv/www/lib/pChart/class/pImage.class.php");
$myData = new pData(); /* Create your dataset object */
$db = mysql_connect("localhost", "", ""); //location of server, db username, db pass
mysql_select_db("PiPlanter_Database", $db);
$Requete = "SELECT * FROM DailyTable07_11_2014__04_05_09PM";
$Result = mysql_query($Requete, $db);
/*This fetches the data from the mysql database, and adds it to pchart as points*/
while($row = mysql_fetch_array($Result))
{
$Time = $row["Time"];
$myData->addPoints($Time,"Time");
$P_MST0 = $row["P_MST0"];
$myData->addPoints($P_MST0,"P_MST0");
$P_MST1 = $row["P_MST1"];
$myData->addPoints($P_MST1,"P_MST1");
$A_TMP0 = $row["A_TMP0"];
$myData->addPoints($A_TMP0,"A_TMP0");
$A_LDR0 = $row["A_LDR0"];
$myData->addPoints($A_LDR0,"A_LDR0");
}
$myData-> setSerieOnAxis("P_MST0", 2);
$myData-> setSerieOnAxis("P_MST1", 2);
$myData-> setAxisName(2, "Relative Moisture [%]");
$myData-> setSerieOnAxis("A_TMP0", 0); //assigns the data to the first axis
$myData-> setAxisName(0, "Degrees [F]"); //adds the label to the first axis
$myData-> setSerieOnAxis("A_LDR0", 1);
$myData-> setAxisName(1, "Ambient Light Level [%]");
$myData->setAbscissa("Time"); //sets the time data set as the x axis label
$myData-> setSerieWeight("P_MST0",1); //draws the line thickness
$myData->setPalette("P_MST0",array("R"=>58,"G"=>95,"B"=>205,"Alpha"=>80)); //sets the line color
$myData-> setSerieWeight("P_MST1",1);
$myData->setPalette("P_MST1",array("R"=>39,"G"=>64,"B"=>139,"Alpha"=>80));
$myData-> setSerieWeight("A_LDR0",2);
$myData-> setSerieTicks("A_LDR0", 4);
$myData-> setSerieWeight("A_TMP0",2);
$myData-> setSerieTicks("A_TMP0", 4);
$myPicture = new pImage(4000,500,$myData); /* Create a pChart object and associate your dataset */
$myPicture->setFontProperties(array("FontName"=>"/srv/www/lib/pChart/fonts/pf_arma_five.ttf","FontSize"=>6)); /* Choose a nice font */
$myPicture->setGraphArea(130,40,3900,300); /* Define the boundaries of the graph area */
$myPicture->drawScale(array("LabelRotation"=>320)); /* Draw the scale, keep everything automatic */
$Settings = array("R"=>250, "G"=>250, "B"=>250, "Dash"=>1, "DashR"=>0, "DashG"=>0, "DashB"=>0);
/*The combination makes a cool looking graph*/
$myPicture->drawPlotChart(array("DisplayValues"=>TRUE));
$myPicture->drawLineChart();
$myPicture->drawLegend(30,320); //adds the legend
//$date-> date("d-M-Y:H:i:s");
//$myPicture->autoOutput(); /* Build the PNG file and send it to the web browser */
$myPicture->render("/home/pi/PiPlanter2/graphs/".date("d-M-Y_H:i:s").".png");
?>
Here are some photos of the current setup, it hasn’t changed much since last time:
Thank you very much for reading.
Hello! Here are some images of the new grow setup:
and here is the working version of the code:
import time
from time import sleep
from time import strftime
import tweepy
consumer_key=""
consumer_secret=""
access_token=""
access_token_secret=""
auth = tweepy.OAuthHandler(consumer_key, consumer_secret)
auth.set_access_token(access_token, access_token_secret)
api = tweepy.API(auth)
PiPlanter_Full = False
import logging
logging.basicConfig()
from apscheduler.scheduler import Scheduler
import os
import sys
import RPi.GPIO as GPIO
GPIO.setmode(GPIO.BOARD)
# Start of mysql setup
import MySQLdb
user = MySQLdb.connect(host="localhost",user="root",passwd="")
cursor = user.cursor()
MySQLdb_Name = 'PiPlanter' + strftime("_%m_%d_%Y_%I_%M_%S%p")
mysql_table_name = MySQLdb_Name + '_table'
mysql_create = 'CREATE DATABASE IF NOT EXISTS PiPlanter'
mysql_grant = "GRANT ALL ON `" + MySQLdb_Name + "`.* TO 'piplanter'@'localhost' IDENTIFIED BY 'password'"
mysql_use = 'USE PiPlanter'
if PiPlanter_Full == True:
#Full PiPlanter
mysql_table = "CREATE TABLE " + mysql_table_name + "(Sample_Number INT NOT NULL AUTO_INCREMENT PRIMARY KEY,Time VARCHAR(100),P_TMP0 VARCHAR(100),P_MST0 VARCHAR(100),P_TMP1 VARCHAR(100),P_MST1 VARCHAR(100),P_TMP2 VARCHAR(100),P_MST2 VARCHAR(100),P_TMP3 VARCHAR(100),P_MST3 VARCHAR(100),A_TMP0 VARCHAR(100),A_LDR0 VARCHAR(100),A_LDR1 VARCHAR(100),A_MST0 VARCHAR(100))"
else:
#Simple PiPlanter
mysql_table = "CREATE TABLE " + mysql_table_name + "(Sample_Number INT NOT NULL AUTO_INCREMENT PRIMARY KEY,Time VARCHAR(100),P_MST0 VARCHAR(100),P_MST1 VARCHAR(100),A_TMP0 VARCHAR(100),A_LDR0 VARCHAR(100))"
#A new database must be created each time the program runs
cursor.execute(mysql_create)
cursor.execute(mysql_grant)
cursor.execute(mysql_use)
cursor.execute(mysql_table)
pins = {'MST_Enable' : 8} #assign names to GPIO pins
for d in pins.itervalues():
GPIO.setup(d,GPIO.OUT)
#first ADC setup on SPI port 1
import spidev
spi_1 = spidev.SpiDev()
spi_1.open(0, 1)
#first ADC setup on SPI port 0
import spidev
spi_0 = spidev.SpiDev()
spi_0.open(0, 0)
#this function can be used to find out the ADC value on ADC 0
def readadc_0(adcnum_0):
if adcnum_0 > 7 or adcnum_0 < 0:
return -1
r_0 = spi_0.xfer2([1, 8 + adcnum_0 << 4, 0])
adcout_0 = ((r_0[1] & 3) << 8) + r_0[2]
return adcout_0
#this function can be used to find out the ADC value on ADC 1
def readadc_1(adcnum_1):
if adcnum_1 > 7 or adcnum_1 < 0:
return -1
r_1 = spi_1.xfer2([1, 8 + adcnum_1 << 4, 0])
adcout_1 = ((r_1[1] & 3) << 8) + r_1[2]
return adcout_1
#this function converts a given value from the ADC and turns it into usable data
def convertadc(adcinput,unit):
millivolts = adcinput*(3300.0/1024.0) #converts the ADC value to milivolts
temp_c = ((millivolts - 100.0)/10)-40.0
percent = (adcinput/1024.0)*100
if unit == 'c' : #used for a temperature sensor to return Celsius
return temp_c
elif unit == 'f' : #used for a temperature sensor to return Fahrenheit
temp_f = (temp_c * 9.0 / 5.0) + 32
return temp_f
elif unit == 'mV':
return millivolts
elif unit == '%':
return percent
else:
print "convertadc input error"
return 0
#returns a usable numerical value from the ADC
def pollsensor(sensor,unit,precision,samples):
GPIO.output(pins['MST_Enable'], True)
if PiPlanter_Full == True:
#Full PiPlanter
sensors = {\
'P_TMP0' : convertadc(readadc_0(0),unit),\
'P_MST0' : convertadc(readadc_0(1),unit),\
'P_TMP1' : convertadc(readadc_0(2),unit),\
'P_MST1' : convertadc(readadc_0(3),unit),\
'P_TMP2' : convertadc(readadc_0(4),unit),\
'P_MST2' : convertadc(readadc_0(5),unit),\
'P_TMP3' : convertadc(readadc_0(6),unit),\
'P_MST3' : convertadc(readadc_0(7),unit),\
'A_TMP0' : convertadc(readadc_1(0),unit),\
'A_LDR0' : convertadc(readadc_1(1),unit),\
'A_LDR1' : convertadc(readadc_1(2),unit),\
'A_MST0' : convertadc(readadc_1(3),unit)}
else:
#Simple PiPlanter
sensors = {\
'P_MST0' : convertadc(readadc_0(0),unit),\
'P_MST1' : convertadc(readadc_0(1),unit),\
'A_TMP0' : convertadc(readadc_0(2),unit),\
'A_LDR0' : convertadc(readadc_0(3),unit)}
outputsum = 0
for x in range(0,samples): #An averaging algorithm that creates a more precise reading
outputsum = outputsum + sensors[sensor]
output = round(outputsum/samples, precision)
GPIO.output(pins['MST_Enable'], False)
return output
#samples all sensors, outputs different formats of the data to be used in other places in the program
def sampleallsensors(sensor_precision,sensor_samples,form):
if PiPlanter_Full == True:
#Full PiPlanter
current_sensors = {\
'P_TMP0' : pollsensor('P_TMP0' , 'f', sensor_precision, sensor_samples),\
'P_MST0' : pollsensor('P_MST0' , '%', sensor_precision, sensor_samples),\
'P_TMP1' : pollsensor('P_TMP1' , 'f', sensor_precision, sensor_samples),\
'P_MST1' : pollsensor('P_MST1' , '%', sensor_precision, sensor_samples),\
'P_TMP2' : pollsensor('P_TMP2' , 'f', sensor_precision, sensor_samples),\
'P_MST2' : pollsensor('P_MST2' , '%', sensor_precision, sensor_samples),\
'P_TMP3' : pollsensor('P_TMP3' , 'f', sensor_precision, sensor_samples),\
'P_MST3' : pollsensor('P_MST3' , '%', sensor_precision, sensor_samples),\
'A_TMP0' : pollsensor('A_TMP0' , 'f', sensor_precision, sensor_samples),\
'A_LDR0' : pollsensor('A_LDR0' , '%', sensor_precision, sensor_samples),\
'A_LDR1' : pollsensor('A_LDR1' , '%', sensor_precision, sensor_samples),\
'A_MST0' : pollsensor('A_MST0' , '%', sensor_precision, sensor_samples)}
else:
#Simple PiPlanter
current_sensors = {\
'P_MST0' : pollsensor('P_MST0' , '%', sensor_precision, sensor_samples),\
'P_MST1' : pollsensor('P_MST1' , '%', sensor_precision, sensor_samples),\
'A_TMP0' : pollsensor('A_TMP0' , 'f', sensor_precision, sensor_samples),\
'A_LDR0' : pollsensor('A_LDR0' , '%', sensor_precision, sensor_samples)}
if form == 'MySQL':
if PiPlanter_Full == True:
#Full PiPlanter
output = "INSERT INTO " + mysql_table_name + "(Time, P_TMP0, P_MST0, P_TMP1, P_MST1, P_TMP2, P_MST2, P_TMP3, P_MST3, A_TMP0, A_LDR0, A_LDR1, A_MST0)" + " VALUES(NOW()" + "," + str(current_sensors['P_TMP0']) + "," + str(current_sensors['P_MST0']) + "," + str(current_sensors['P_TMP1']) + "," + str(current_sensors['P_MST1']) + "," + str(current_sensors['P_TMP2']) + "," + str(current_sensors['P_MST2']) + "," + str(current_sensors['P_TMP3']) + "," + str(current_sensors['P_MST3']) + "," + str(current_sensors['A_TMP0']) + "," + str(current_sensors['A_LDR0']) + "," + str(current_sensors['A_LDR1']) + "," + str(current_sensors['A_MST0']) + ")"
else:
#Simple PiPlanter
output = "INSERT INTO " + mysql_table_name + "(Time, P_MST0, P_MST1, A_TMP0, A_LDR0)" + " VALUES(NOW()" + "," + str(current_sensors['P_MST0']) + "," + str(current_sensors['P_MST1']) + "," + str(current_sensors['A_TMP0']) + "," + str(current_sensors['A_LDR0']) + ")"
elif form == 'Console':
if PiPlanter_Full == True:
#Full PiPlanter
output = 'Debug Update:' + ' P_TMP0: ' + str(str(current_sensors['P_TMP0'])) + ',' + ' P_MST0: ' + str(str(current_sensors['P_MST0'])) + ',' + ' P_TMP1: ' + str(str(current_sensors['P_TMP1'])) + ',' + ' P_MST1: ' + str(str(current_sensors['P_MST1'])) + ','+ ' P_TMP2: ' + str(str(current_sensors['P_TMP2'])) + ','+ ' P_MST2: ' + str(str(current_sensors['P_MST2'])) + ','+ ' P_TMP3: ' + str(str(current_sensors['P_TMP3'])) + ','+ ' P_MST3: ' + str(str(current_sensors['P_MST3'])) + ',' + ' A_TMP0: ' + str(str(current_sensors['A_TMP0'])) + ',' + ' A_LDR0: ' + str(str(current_sensors['A_LDR0'])) + ','+ ' A_LDR1: ' + str(str(current_sensors['A_LDR1'])) + ','+ ' A_MST0: ' + str(str(current_sensors['A_MST0']))
else:
#Simple PiPlanter
output = 'Debug Update:' + ' P_MST0: ' + str(str(current_sensors['P_MST0'])) + ',' + ' P_MST1: ' + str(str(current_sensors['P_MST1'])) + ',' + ' A_TMP0: ' + str(str(current_sensors['A_TMP0'])) + ',' + ' A_LDR0: ' + str(str(current_sensors['A_LDR0']))
elif form == 'Twitter':
if PiPlanter_Full == True:
#Full PiPlanter
output = 'Ambient LDR: ' + str(round(((current_sensors['A_LDR0'] + current_sensors['A_LDR1'])/2),1) ) + '%, ' + 'Ambient Tmp: ' + str(round(current_sensors['A_TMP0'],1)) + 'DF, ' + 'Average Plant Tmp: ' + str(round( (current_sensors['P_TMP0'] + current_sensors['P_TMP1'] + current_sensors['P_TMP2'] + current_sensors['P_TMP3'] )/4, sensor_precision-2)) + 'DF, ' + 'Ambient Mst: ' + str(round(current_sensors['A_MST0'],2)) + '%, ' + 'Average Plant Mst: ' + str(round( (current_sensors['P_MST0']+current_sensors['P_MST1']+ current_sensors['P_MST2']+ current_sensors['P_MST3'] )/4 ,1)) + '%'
else:
#Simple PiPlanter
output = 'Ambient Light: ' + str(round((current_sensors['A_LDR0']),1)) + '%, ' + 'Ambient Temp: ' + str(round(current_sensors['A_TMP0'],1)) + 'DF, ' + 'Average Plant Mst: ' + str(round( (current_sensors['P_MST0']+current_sensors['P_MST1'])/2 ,1)) + '%'
else:
print "convertadc input sampleallsensors"
return 0
return output
pumps = {'PUMP0' : 7, 'PUMP1' : 11, 'PUMP2' : 13, 'PUMP3' : 16} #assign names to GPIO pins
for k in pumps.itervalues():
GPIO.setup(k,GPIO.OUT)
#pumps a given amount of water from a given pump
def pumpwater(pump,volume):
LPM = 4.00 #L per minute
ontime = volume*(60/LPM)
GPIO.output(pumps[pump],True)
time.sleep(ontime)
GPIO.output(pumps[pump],False)
output = 'Pumped ' + str(volume) + ' L of water into plants in ' + str(ontime) + ' seconds.'
return output
#Sets up proper directories for folders and images
def visualssetup(time):
#checks if directories above exist
if not os.path.exists(str(os.getcwd()) + '/videos/'):
os.makedirs(str(os.getcwd()) + '/videos/')
if not os.path.exists(str(os.getcwd()) + '/videos/dailys/'):
os.makedirs(str(os.getcwd()) + '/videos/dailys/')
if not os.path.exists(str(os.getcwd()) + '/images/'):
os.makedirs(str(os.getcwd()) + '/images/')
if not os.path.exists(str(os.getcwd()) + '/images/dailys/'):
os.makedirs(str(os.getcwd()) + '/images/dailys/')
global current_dailypicdir
current_dailypicdir = str(os.getcwd()) + '/images/dailys/' + str(time) + '/'
os.makedirs(current_dailypicdir)
global current_dailyvideodir
current_dailyvideodir = str(os.getcwd()) + '/videos/dailys/' + str(time) + '/'
os.makedirs(current_dailyvideodir)
def picture(dir,cycle):
image = dir + str(cycle).zfill(4) + '.jpg'
picture_command = 'raspistill -o ' + dir + str(cycle).zfill(4) + '.jpg'
os.system(picture_command)
return image
def rendervideo():
time = strftime("%m-%d-%Y_%I-%M-%S%p")
global current_videodir
scheduler.shutdown(shutdown_threadpool=False)
render_command = 'sudo mencoder -nosound mf://' + current_dailypicdir + '*.jpg -mf w=2592:h=1944:type=jpg:fps=15 -ovc lavc -lavcopts vcodec=mpeg4:vbitrate=2160000:mbd=2:keyint=132:v4mv:vqmin=3:lumi_mask=0.07:dark_mask=0.2:mpeg_quant:scplx_mask=0.1:tcplx_mask=0.1:naq -o ' + current_dailyvideodir + 'output.avi'
os.system(render_command)
def daily():
visualssetup(strftime("%m-%d-%Y_%I-%M-%S%p"))
api.update_status(pumpwater('PUMP0',3))
global cycle
cycle = 0
def hourly():
cursor.execute(sampleallsensors(3,20,'MySQL'))
user.commit()
print sampleallsensors(3,20,'Console')
pumpwater('PUMP0', .5)
global current_dailypicdir
api.update_status(sampleallsensors(3,20,'Twitter') + " https://esologic.com/?page_id=1042")
picture(current_dailypicdir,cycle)
#pumpwater('PUMP0', 1)
global cycle
cycle = cycle + 1
if __name__ == '__main__':
daily()
hourly()
scheduler = Scheduler(standalone=True)
scheduler.add_interval_job(hourly, hours=1)
scheduler.add_interval_job(daily, days=1)
try:
scheduler.start()
except (KeyboardInterrupt, SystemExit):
pass
I’ll do a much more thorough post when the project is further along. For those playing along at home, you can see that I’ve totally re-written the code for this new version. So far, it has much less functionality but much more stability and flexibility.
I have come to a very good place with my media server setup using my Raspberry Pi. The whole thing is accessible using the network, over a wide range of devices which is ideal for me and the other people living in my house.
If you don’t need to see any of the installation, the following software is running on the server: Samba, Minidlna, Deluge & Deluge-Web and NTFS-3G.
The combination of all of this software allows me to access my media and files on pretty much any device I would want to. This is a great combination of software to run on your Pi if you’re not doing anything with it.
So let’s begin with the install!
I’m using the latest build of Raspian, the download and install of that is pretty simple, instructions here.
Unless you can hold your media on the SD card your Pi’s OS is installed on, you’ll need some kind of external storage. In my case, I’m using a 3TB external HDD.
We’ll need to mount this drive, I’ve already written a post on how to do this, check that out here.
Now we should involve Samba. Again, it’s a pretty simple install.
sudo apt-get install samba samba-common-bin
Once it installs you should already see signs of it working. If you’re on windows, make sure network sharing is on, and browse to the “network” folder. It should show up as “RASPBERRYPI” as seen in this image:
The only real tricky part is configuring it. Here is an untouched version of the samba config file. On your pi, it is found at:
/etc/samba/smb.conf
There are only a few differences between the standard version and the version I’m using. The biggest one being the actual “Share” being used seen here:
[HDD_Share] comment = External HDD Share path = /media/USBHDD browseable = yes read only = no valid users = YOURUSER #IF ON A BASIC RASPBERRY PI, US THE USER "pi" only guest = no create mask = 0777 directory mask = 0777 public = no
Basically, this shares the external HDD you just mounted to the network. You can insert this share anywhere in your document and it will work. Once you update your config file, you have to add your user to samba. If you haven’t done anything but install raspbian, your username on the pi should still be “pi” so the following should do the following:
sudo smbpasswd -a pi
Enter your new samba password twice and then you’re good to go after restarting samba.
sudo /etc/init.d/samba restart
In windows you can go to “network” option in My Computer and see your share.
If you’re like me though, you’re going to want multiple users for multiple shares. Samba only can only have users that are members of the system, so in order to add a new user to samba, you have to add a user to the Raspberry Pi. For example, let’s add the user ‘testuser’:
sudo mkdir /home/testuser/ sudo useradd -d /home/testuser -s /bin/false -r testuser sudo passwd testuser sudo chown testuser /home/testuser sudo chgrp users /home/testuser sudo smbpasswd -a testuser sudo /etc/init.d/samba restart
I have written a bash script to do this automatically.
On the share level, the line of valid users = should be set to whichever user you want to be able to use the share.
That’s pretty much it for Samba. I’m probably going to do a guide on accessing your shares via SSH tunneling when the need for me to do so arises. I’ll link that here if it ever happens. Now on to minidlna.
MiniDLNA is a very lightweight DLNA server. DLNA is a protocal specifically for streaming media to a huge array of devices from computers to iOS devices or gaming consoles or smart TV’s. I have spent quite a bit of time using minidlna, and have reached a configuration that works extremely well with the raspberry pi. The install is very easy, much like samba, it’s the configuration that is tricky.
sudo apt-get install minidlna
The config file i’m using is found here. There Pi actually handles the streaming really really well, and there only a few things you need to change in the config file, and they are mostly aesthetic. The following lines are examples of media locations for each type of file.
# If you want to restrict a media_dir to a specific content type, you can # prepend the directory name with a letter representing the type (A, P or V), # followed by a comma, as so: # * "A" for audio (eg. media_dir=A,/var/lib/minidlna/music) # * "P" for pictures (eg. media_dir=P,/var/lib/minidlna/pictures) # * "V" for video (eg. media_dir=V,/var/lib/minidlna/videos) # # WARNING: After changing this option, you need to rebuild the database. Either # run minidlna with the '-R' option, or delete the 'files.db' file # from the db_dir directory (see below). # On Debian, you can run, as root, 'service minidlna force-reload' instead. media_dir=A,/media/USBHDD/Documents/Media/Audio media_dir=P,/media/USBHDD/Documents/Media/Images/Photos media_dir=V,/media/USBHDD/Documents/Media/Video media_dir=/media/USBHDD/Documents/Media/
And changing this line will change the name of the DLNA server on the network:
# Name that the DLNA server presents to clients. friendly_name=Raspberry Pi DLNA
That’s pretty much all there is to it.
You can stream the files all over the place, the following images show it being used on my kindle and another computer. I stream files to my xbox 360 all the time.
The last major component of this media server is Deluge, let’s proceed with that install.
Deluge is a torrent client for linux servers. The coolest part is it has a very good web based GUI for control. The install isn’t too straightforward, but there is no real specific configuration. The following commands will get things up and running.
sudo apt-get install python-software-properties sudo add-apt-repository 'deb http://ppa.launchpad.net/deluge-team/ppa/ubuntu precise main' sudo apt-get update sudo apt-get install -t precise deluge-common deluged deluge-web deluge-console sudo apt-get install -t precise libtorrent-rasterbar6 python-libtorrent sudo apt-get install screen deluged screen -d -m deluge-web
And there you go! You can now torrent files directly into your Samba shares which is hugely useful and more secure, the following is me doing just that:
The last thing that needs to be done is run a few commands at boot, particularly mount the HDD and start deluge-web. The easiest way to do this crontab. First run:
sudo crontab -e
Then add the following two lines:
sudo mount -t ntfs-3g /dev/sda1/ /media/USBHDD/ screen -d -m deluge-web
So it looks like this:
And everything will start working upon boot!
Thank you very much for reading. If you have any questions, please leave a comment.
They’re getting bigger!