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:
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 |
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:
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 |
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!
|
1 2 3 4 5 |
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.
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 |
#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:
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 |
[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.
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 202 203 204 205 206 207 208 209 210 211 212 213 214 215 216 217 218 219 220 221 222 223 224 225 226 227 228 229 230 231 232 233 234 235 236 237 238 239 240 241 242 243 244 245 246 247 248 249 250 251 252 253 254 255 256 257 258 259 260 261 262 263 264 265 266 267 268 269 270 271 272 273 274 275 276 277 278 279 280 281 282 283 284 285 286 287 288 289 290 291 292 293 294 295 296 297 298 299 300 301 302 303 304 305 306 307 308 309 310 311 312 313 314 315 316 317 318 319 320 321 322 323 324 325 326 327 328 329 330 331 332 333 334 335 336 337 338 339 340 341 342 343 344 345 346 347 348 349 350 351 352 353 354 355 356 357 358 359 360 361 362 363 364 365 366 367 368 369 370 371 372 373 374 375 376 377 378 379 380 381 382 383 384 385 386 387 388 389 390 391 392 393 394 395 396 397 398 399 400 401 402 403 404 405 406 407 408 409 410 411 412 413 414 415 416 417 418 419 420 421 422 423 424 425 426 427 428 429 430 431 432 |
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:
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 |
<?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:
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 202 203 204 205 206 207 208 209 210 211 212 213 214 215 216 217 218 219 220 221 222 223 224 225 226 227 228 229 230 231 232 233 234 235 236 237 238 239 240 241 242 243 244 245 246 247 248 249 250 251 252 253 254 255 256 257 258 259 260 261 262 263 264 265 266 267 268 269 270 |
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.
|
1 |
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:
|
1 |
/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:
|
1 2 3 4 5 6 7 8 9 10 |
[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:
|
1 |
sudo smbpasswd -a pi |
Enter your new samba password twice and then you’re good to go after restarting samba.
|
1 |
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’:
|
1 2 3 4 5 6 7 |
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.
|
1 |
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.
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 |
# 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:
|
1 2 |
# 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.
|
1 2 3 4 5 6 7 8 |
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:
|
1 |
sudo crontab -e |
Then add the following two lines:
|
1 2 |
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!