views:

257

answers:

1

I've recently built a Tweet A Watt (http://www.ladyada.net/make/tweetawatt/) wireless power monitor, which uses XBee for data transfer. I'm attempting to get the Tweet A Watt data into Processing for use in creating some visual energy feedback prototypes. Using the XBee API Library for Processing (http://www.faludi.com/code/xbee-api-library-for-processing/), I've made some headway, but have come up against an obstacle that I would appreciate any input on.

My Processing sketch looks like this:

/*
XBee Communication Prototype
XBee API Library by Daniel Shiffman and Rob Faludi: http://www.faludi.com/code/xbee-api-library-for-processing/
Sample XBee communication code adapted from Tom Igoe: http://www.tigoe.net/pcomp/code/category/Processing/148
*/

//import the xbee and serial libraries:
import xbee.*;
import processing.serial.*;

// set up Xbee parameters:
Serial port;
XBeeReader xbee;
int rssi = 0;     // received signal strength
int address = 0;     // sender's address
int samples = 0;     // total number of samples
int[] analog;     // values from the analog I/O pins

void setup() {
  // set up xbee
  port = new Serial(this, Serial.list()[0], 9600);
  xbee = new XBeeReader(this, port);
  xbee.startXBee();  
}

void draw() {}    

// called every time an XBee event is received: every 2s in the case of the Tweet A Watt
public void xBeeEvent(XBeeReader xbee) {    
   // Grab a frame of data
   XBeeDataFrame data = xbee.getXBeeReading();   

  println("");
  println("LOOP " + hour() + ":" + minute() + ":" + second());

    // Get the transmitter address
    address = data.getAddress16();
    println("API ID: " + address);    

    // Get the RSSI
    rssi = data.getRSSI();
  println("RSSI: " + rssi);      

  // Get total number of samples
  samples = data.getTotalSamples();   
  println("Total Samples: " + samples);    

  // Output the Analog readings for each sample     
  // ONLY GETS FIRST SAMPLE - How do I access all samples?
  for (int i=0; i < samples; i++) {
   analog = data.getAnalog(i);
   print("[");
   for (int j=0; j < analog.length; j++) {
    print(analog[j]);
    if (j < analog.length - 1) { print(", "); }
   }
   print("]");
   if (i < samples - 1) { print(", "); }
   else { println(""); }
  }
}

This all works as expected. The xBeeEvent is called every 2s, and outputs the correct values for the API ID, RSSI, and Total Samples (19). However, when outputting the contents of the analog readings, I seem to be getting the first sample repeated 19 times. See this sample output:

LOOP 10:37:57
API ID: 1
RSSI: -61
Total Samples: 19
[512, -1, -1, -1, 688, -1], [512, -1, -1, -1, 688, -1], [512, -1, -1, -1, 688, -1], [512, -1, -1, -1, 688, -1], [512, -1, -1, -1, 688, -1], [512, -1, -1, -1, 688, -1], [512, -1, -1, -1, 688, -1], [512, -1, -1, -1, 688, -1], [512, -1, -1, -1, 688, -1], [512, -1, -1, -1, 688, -1], [512, -1, -1, -1, 688, -1], [512, -1, -1, -1, 688, -1], [512, -1, -1, -1, 688, -1], [512, -1, -1, -1, 688, -1], [512, -1, -1, -1, 688, -1], [512, -1, -1, -1, 688, -1], [512, -1, -1, -1, 688, -1], [512, -1, -1, -1, 688, -1], [512, -1, -1, -1, 688, -1]

LOOP 10:38:59
API ID: 1
RSSI: -61
Total Samples: 19
[503, -1, -1, -1, 561, -1], [503, -1, -1, -1, 561, -1], [503, -1, -1, -1, 561, -1], [503, -1, -1, -1, 561, -1], [503, -1, -1, -1, 561, -1], [503, -1, -1, -1, 561, -1], [503, -1, -1, -1, 561, -1], [503, -1, -1, -1, 561, -1], [503, -1, -1, -1, 561, -1], [503, -1, -1, -1, 561, -1], [503, -1, -1, -1, 561, -1], [503, -1, -1, -1, 561, -1], [503, -1, -1, -1, 561, -1], [503, -1, -1, -1, 561, -1], [503, -1, -1, -1, 561, -1], [503, -1, -1, -1, 561, -1], [503, -1, -1, -1, 561, -1], [503, -1, -1, -1, 561, -1], [503, -1, -1, -1, 561, -1]

As you can see, the first sample is repeated 19 times. Running the original Python script from the Tweet A Watt software (wattcher.py) outputs a similar reading of the XBee packet, but with 19 distinct samples. This is the state I'm trying to get to in Processing.

In the XBee API Library, the getAnalog() and getAnalog(n) functions are defined as follows:

getAnalog() – returns an array of integers that represents the current state of each analog channel with -1 indicating that the channel is not configured for analog. Use this when there is only one sample per frame.

getAnalog(int n) – returns the nth sample of analog data as an array of integers with -1 indicating that the channel is not configured for analog.

I'm using getAnalog(int n) in the for loop. Is the issue that I am only getting one "frame" of data, in the call to XBeeDataFrame data = xbee.getXBeeReading(); ?

I've also tried reading the Serial packet directly without using the XBee API Library (with reference to (http://www.tigoe.net/pcomp/code/category/Processing/8), (http://processing.org/reference/libraries/serial/Serial.html), and (http://ssdl.stanford.edu/ssdl/images/stories/AA236/0708A/Lab/Rover/Parts/xbeeproproductmanual.pdf), but my lack of experience in this area makes this a bit of a non-starter.

If anyone familiar with the XBee packet, the XBee API Library, or reading Serial data in Processing can assist, it would be greatly appreciated. I expect that the data is there, I'm just not accessing it correctly. I realize this is quite a specific question, and I've posted it in the Adafruit (makers of the Tweet A Watt kit - http://forums.adafruit.com/viewtopic.php?f=40&amp;t=16067&amp;sid=4e34727fa59b7c7d589564d2d6b85e46) and Processing (http://processing.org/discourse/yabb2/YaBB.pl?num=1276111549) forums, but after dozens of views I haven't had any replies, so I figured I'd cast the net a little wider.

If I've left out anything that would be helpful, please let me know. Thanks in advance for your help.

A: 

Wondering if you made any progress on this since you posted? I'm trying to use the tweet a watt data directly in processing as well - right now I'm sending the info to a csv from python and then processing reads the csv every 5 seconds. But there are problems with this from the python side and I'm frustrated because I am trying to solve these problems without knowing anything about python! This is what I've come up with in processing to continually read the csv file and update the data:

String[] consumption; int index = 1;

void setup() { consumption = loadStrings("powerdatalog.csv"); frameRate(0.20); }

void draw() { if (index < consumption.length) { String[] allinfo = split(consumption[index], '\t'); if (allinfo.length == 1) {
float x = float(allinfo[0]); String w = str(x); String[] avgwatt = splitTokens(allinfo[0], ", "); float consumptionWatt = float(avgwatt[5]); println(consumptionWatt); } index = index + 1; } }

But I would love to do all of this directly in processing without using python.

ledled