Portal
3.00 (2 Bewertungen)
| 
Sie hat 1200 MHz und ist schnell genug als Server und Logger zu arbeiten.
Dabei ligt der Stromverbrauch bei geringen 5 Watt.
Ich logge mit der Dockstar bereits meine beiden Solarmaxe.
Dies geschieht nach zagibus SolarMax Datenlogger über die RS485 - er Schnittstelle.
datenlogger-f5/solarmax-datenlogger-t52179.html
Ich möchte nun ebenfalls meine drei Delta si 5000 loggen.
Da ich im Programmieren nicht sehr geübt bin, hoffe ich auf zagibus und anderer Experten Unterstützung hier im Forum.
Als Basis hier mein Logger, so wie er meine Solarmaxe über die RS485 er Schnittstelle abfragt:
- Code: Alles auswählen
/*
Simple solarmax logger c program written by zagibu@gmx.ch in July 2010
This program was originally licensed under WTFPL 2 http://sam.zoy.org/wtfpl/
It is now licensed under GPLv2 or later http://www.gnu.org/licenses/gpl2.html
You need the mysql client library files installed to be able to compile it.
Compile with:
gcc -W -Wall -Wextra -Wshadow -Wlong-long -Wformat -Wpointer-arith -rdynamic -pedantic-errors -std=c99 -o sollog sollog.c -lmysqlclient
Run with:
./sollog /home/fritz/Desktop/loggertest/sollog.conf
./sollog /usr/bin/sollog.conf
Structure of the config-file:
Debug=0
Loginterval=60
Waitinterval=200
DBhost=localhost
DBname=solarmax
DBtabprefix=log
DBuser=solaruser
DBpass=userpassword
Hostname=192.168.178.35
Hostport=12345
NumberOfInverters=1
You can set DEBUG to 1 to get detailed output in a separate logfile.
It is recommended to schedule the smw-logger to be started between 5:00 - 6:00 in the
morning and stopped between 22:00 and 23:00 in the evening (compare with sunshine
duration). The smw-logger has no built-in facility for logging, so use CRON or similar.
Example CRON entries:
00 05 * * * /usr/local/bin/logger /usr/local/etc/logger.conf
00 23 * * * killall logger
Sources:
- http://www.linuxhowtos.org/C_C++/socket.htm
- http://wwwuser.gwdg.de/~kboehm/ebook/21_kap15_w6.html#49329
- http://man.cx/setbuf%283%29
- http://allfaq.org/forums/t/169895.aspx
- http://dev.mysql.com/tech-resources/articles/mysql-capi-tutorial.html
*/
#define _GNU_SOURCE
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <strings.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <netdb.h>
#include <mysql/mysql.h>
#include <regex.h>
#include <time.h>
#include <unistd.h>
#include <fcntl.h>
#include <errno.h>
#include <pthread.h>
#include <termios.h>
# define TERM_DEVICE "/dev/ttyUSB0" /* = COM1 / USB */
# define TERM_SPEED B19200 /* Bit/Sek */
int i, fd, old_flags, log_interval, integer, integerout,integerout2,j, PACcount;
int integerout1[8];
ssize_t length;
struct termios term_attr;
FILE* file;
char* file_name;
char outbuffer[512]={0};
// char outbuffer[512] = "KDY=B;KMT=40;KYR=B9F;KT0=1154;TNF=1388;TKK=19;PAC=5C;PRL=1;IL1=54;IDC=1A;UL1=910;UDC=A2C;SYS=FFFF|";
char text[256];
char inbuffer[1];
char* mode = "a";
char* message = "{FB;01;46|64:KDY;KMT;KYR;KT0;TNF;TKK;PAC;PRL;IL1;IDC;UL1;UDC;SYS|1199}";
// time_t timestamp;
time_t t;
struct tm *ts;
FILE* error_file = NULL;
char* error_file_name = "/var/log/solarmax-error.log";
char* error_mode = "w";
FILE* debug_file = NULL;
char* debug_file_name = "/var/log/solarmax-debug.log";
char* debug_mode = "w";
FILE* config_file = NULL;
char* config_file_name;
char* config_mode = "r";
int sockfd, portno, n, log_interval, result, counter, wait_interval, active_max, nr_of_maxes, DEBUG;
int lost_connection = 0;
struct sockaddr_in serv_addr;
struct hostent* server;
char dbhost[512];
char dbname[512];
char dbtabprefix[512];
char dbuser[512];
char dbpass[512];
char hostaddr[512];
char line[512];
char* message;
char* expression = "...=([0-9A-F]*);...=([0-9A-F]*);...=([0-9A-F]*);...=([0-9A-F]*);...=([0-9A-F]*);...=([0-9A-F]*);...=([0-9A-F]*);...=([0-9A-F]*);...=([0-9A-F]*);...=([0-9A-F]*);...=([0-9A-F]*);...=([0-9A-F]*);...=([0-9A-F]*)";
int kdy, kmt, kyr, kt0, tnf, tkk, pac, prl, il1, idc, ul1, udc, sys;
char buffer2[512];
// char buffer [512] = {"KDY=B;KMT=40;KYR=B9F;KT0=1154;TNF=1388;TKK=19;PAC=5C;PRL=1;IL1=54;IDC=1A;UL1=910;UDC=A2C;SYS=FFFF;"};
char buffer[512];
char query[512];
char* temp;
regex_t rx;
regmatch_t* matches;
MYSQL* connection = NULL;
void error_exit(const char* msg) {
perror(msg);
if (error_file != NULL)
fclose(error_file);
if (debug_file != NULL)
fclose(debug_file);
exit(0);
}
void debug_entry(char* msg) {
time_t timestamp = time(NULL);
char debug_msg[512];
char *time_now = ctime(×tamp);
time_now[strlen(time_now)-1]=0;
if (debug_file == NULL)
error_exit("ERROR writing to debug.log file");
sprintf(debug_msg, "%s %s", time_now, msg);
fprintf(debug_file, "%s\n", debug_msg);
}
void error_retry(char* msg) {
time_t timestamp = time(NULL);
char error_msg[512];
char *time_now = ctime(×tamp);
time_now[strlen(time_now)-1]=0;
if (error_file == NULL)
error_exit("ERROR writing to error.log file");
sprintf(error_msg, "%s %s", time_now, msg);
fprintf(error_file, "%s\n", error_msg);
}
void set_nonblock(int sock) {
int flags;
flags = fcntl(sock,F_GETFL,0);
if (flags == -1)
error_exit("ERROR no valid flags on socket");
fcntl(sock, F_SETFL, flags | O_NONBLOCK);
}
int main(int argc, char *argv[]) {
// Check commandline arguments
if (argc < 2)
error_exit("ERROR program needs config-file as parameter");
// Try to open error log file
if ((error_file = fopen(error_file_name, error_mode)) == NULL)
error_exit("ERROR opening error.log file");
// Make file unbuffered
setbuf(error_file, NULL);
//Read Config File
config_file_name = argv[1];
FILE *fp = fopen(config_file_name, config_mode);
// Read variables
if (fp) {
while (fgets(line, sizeof(line), fp)) {
sscanf(line, "Debug=%d[^\n]", &DEBUG);
sscanf(line, "Loginterval=%d[^\n]", &log_interval);
sscanf(line, "Waitinterval=%d[^\n]", &wait_interval);
sscanf(line, "DBhost=%[^\n]", dbhost);
sscanf(line, "DBname=%[^\n]", dbname);
sscanf(line, "DBtabprefix=%[^\n]", dbtabprefix);
sscanf(line, "DBuser=%[^\n]", dbuser);
sscanf(line, "DBpass=%[^\n]", dbpass);
sscanf(line, "Hostname=%[^\n]", hostaddr);
sscanf(line, "Hostport=%d[^\n]", &portno);
sscanf(line, "NumberOfInverters=%d[^\n]", &nr_of_maxes);
}
}
fclose(fp);
// Try to open debug log file, if necessary
if(DEBUG) {
if((debug_file = fopen(debug_file_name, debug_mode)) == NULL)
error_exit("ERROR opening debug.log file");
// Make file unbuffered
setbuf(debug_file, NULL);
}
// Try to compile regular expression
result = regcomp(&rx, expression, REG_EXTENDED);
if (result != 0) {
regerror(result, &rx, expression, sizeof(expression));
regfree(&rx);
sprintf(buffer, "ERROR invalid regular expression: %s", expression);
error_exit(buffer);
}
// Try to reserve memory for matches
matches = (regmatch_t *) malloc((rx.re_nsub + 1) * sizeof(regmatch_t));
if (!matches)
error_exit("Out of memory");
// Connect to database
connection = mysql_init(NULL);
if (!mysql_real_connect(connection, dbhost, dbuser, dbpass, dbname, 0, NULL, 0))
error_exit(mysql_error(connection));
if (DEBUG) {
sprintf(buffer, "Connected to database %s on host %s", dbname, dbhost);
debug_entry(buffer);
}
if ((fd = open(TERM_DEVICE, O_RDWR)) == -1)
{
perror("terminal: Can't open device " TERM_DEVICE);
return(1);
}
/* RS232 konfigurieren */
if (tcgetattr(fd, &term_attr) != 0)
{
perror("terminal: tcgetattr() failed");
return(1);
}
term_attr.c_cflag = TERM_SPEED | CS8 | CLOCAL | CREAD;
term_attr.c_iflag = 0;
term_attr.c_oflag = OPOST | ONLCR;
term_attr.c_lflag = 0;
if (tcsetattr(fd, TCSAFLUSH, &term_attr) != 0)
perror("terminal: tcsetattr() failed");
/* Std.-Eingabe anpassen */
tcgetattr(STDIN_FILENO, &term_attr) ;
/* alte Einst. sichern */
old_flags = term_attr.c_lflag;
term_attr.c_lflag &= ~(ICANON | ECHO);
tcsetattr(STDIN_FILENO, TCSAFLUSH, &term_attr) ;
/* */
while (1) {
// set variable to default value or it will keep trying to reconnect
lost_connection = 0;
// Check if connection to db-server must be re-established
if (mysql_ping(connection)) {
// Connect to database
if (!mysql_real_connect(connection, dbhost, dbuser, dbpass, dbname, 0, NULL, 0))
error_exit(mysql_error(connection));
if (DEBUG) {
sprintf(buffer, "Connected to database %s on host %s", dbname, dbhost);
debug_entry(buffer);
}
}
// Start sending the data requests and logging the answers
while (1) {
/*
// We have to get out of this while-loop to reestablish the connection to the inverter
if (lost_connection){
debug_entry("Looks like we lost our connection to solarmax, reconnecting...");
break;
}
*/
// Get the current time
time_t start_time = time(NULL);
for(active_max = 1; active_max <= nr_of_maxes; active_max++){
// Generate message according to device address of solarmax:
// Could be something like this:
// sprintf(message, "{FB;0%d;46|64:KDY;KMT;KYR;KT0;TNF;TKK;PAC;PRL;IL1;IDC;UL1;UDC;SYS|%s}", active_max, 16_bit_checksum
// For further information on the protocol refer to: http://blog.dest-unreach.be/2009/04/15/solarmax-maxtalk-protocol-reverse-engineered
// Until someone comes up with a nice solution to calculate the checksum, lets stick to a few precalculated message strings (tested only for 2 maxes!):
if (active_max == 1) {
message = "{FB;01;46|64:KDY;KMT;KYR;KT0;TNF;TKK;PAC;PRL;IL1;IDC;UL1;UDC;SYS|1199}";
}
else if (active_max == 2) {
message = "{FB;02;46|64:KDY;KMT;KYR;KT0;TNF;TKK;PAC;PRL;IL1;IDC;UL1;UDC;SYS|119A}";
}
else if (active_max == 3) {
message = "{FB;03;46|64:KDY;KMT;KYR;KT0;TNF;TKK;PAC;PRL;IL1;IDC;UL1;UDC;SYS|119B}";
}
else if (active_max == 4) {
message = "{FB;04;46|64:KDY;KMT;KYR;KT0;TNF;TKK;PAC;PRL;IL1;IDC;UL1;UDC;SYS|119C}";
}
else if (active_max == 5) {
message = "{FB;05;46|64:KDY;KMT;KYR;KT0;TNF;TKK;PAC;PRL;IL1;IDC;UL1;UDC;SYS|119D}";
}
else if (active_max == 6) {
message = "{FB;06;46|64:KDY;KMT;KYR;KT0;TNF;TKK;PAC;PRL;IL1;IDC;UL1;UDC;SYS|119E}";
}
else if (active_max == 7) {
message = "{FB;07;46|64:KDY;KMT;KYR;KT0;TNF;TKK;PAC;PRL;IL1;IDC;UL1;UDC;SYS|119F}";
}
else if (active_max == 8) {
message = "{FB;08;46|64:KDY;KMT;KYR;KT0;TNF;TKK;PAC;PRL;IL1;IDC;UL1;UDC;SYS|11A0}";
}
else if (active_max == 9) {
message = "{FB;09;46|64:KDY;KMT;KYR;KT0;TNF;TKK;PAC;PRL;IL1;IDC;UL1;UDC;SYS|11A1}";
}
else {
error_exit("ERROR invalid hardware address; currently works only for 9 maxes");
}
if (DEBUG) {
sprintf(buffer, "Sending message: %s", message);
debug_entry(buffer);
}
// Send message 1
length = write(fd,message,strlen(message));
if (length < 0)
break;
if (DEBUG)
printf("WR= message gesendet: %s\n", message);
// Read answer
bzero(inbuffer, 1);
bzero(buffer, 512);
for (i=0; i < 512; i++)
{
length = read(fd, inbuffer,1);
buffer[i]= inbuffer[0];
if (inbuffer[0] == '}')
{
buffer[i+1] = '\0';
break;
}
}
if (length < 0)
break;
buffer[i] = '\0';
buffer[i-1] = '\0';
buffer[i-2] = '\0';
buffer[i-3] = '\0';
buffer[i-4] = '\0';
buffer[i-5] = '\0';
strcat(buffer, ";SYS=FFFF;");
if (DEBUG)
printf("Received answer: %s\n", buffer);
// char buffer [512] = "KDY=B;KMT=40;KYR=B9F;KT0=1154;TNF=1388;TKK=19;PAC=5C;PRL=1;IL1=54;IDC=1A;UL1=910;UDC=A2C;SYS=FFFF;";
if (DEBUG) {
sprintf(buffer2, "Received answer: %s", buffer);
debug_entry(buffer2);
}
// Extract the data fields from answer
result = regexec(&rx, buffer, rx.re_nsub + 1, matches, 0);
if (result) {
regerror(result, &rx, buffer, sizeof(buffer));
//error_exit("ERROR no regexp match");
error_retry("ERROR no regexp match");
lost_connection = 1;
break;
}
// Convert the extracted data fields to integer values
temp = strndup(buffer + matches[1].rm_so, matches[1].rm_eo - matches[1].rm_so);
kdy = strtol(temp, NULL, 16);
free(temp);
temp = strndup(buffer + matches[2].rm_so, matches[2].rm_eo - matches[2].rm_so);
kmt = strtol(temp, NULL, 16);
free(temp);
temp = strndup(buffer + matches[3].rm_so, matches[3].rm_eo - matches[3].rm_so);
kyr = strtol(temp, NULL, 16);
free(temp);
temp = strndup(buffer + matches[4].rm_so, matches[4].rm_eo - matches[4].rm_so);
kt0 = strtol(temp, NULL, 16);
free(temp);
temp = strndup(buffer + matches[5].rm_so, matches[5].rm_eo - matches[5].rm_so);
tnf = strtol(temp, NULL, 16);
free(temp);
temp = strndup(buffer + matches[6].rm_so, matches[6].rm_eo - matches[6].rm_so);
tkk = strtol(temp, NULL, 16);
free(temp);
temp = strndup(buffer + matches[7].rm_so, matches[7].rm_eo - matches[7].rm_so);
pac = strtol(temp, NULL, 16) /2 ;
free(temp);
temp = strndup(buffer + matches[8].rm_so, matches[8].rm_eo - matches[8].rm_so);
prl = strtol(temp, NULL, 16);
free(temp);
temp = strndup(buffer + matches[9].rm_so, matches[9].rm_eo - matches[9].rm_so);
il1 = strtol(temp, NULL, 16);
free(temp);
temp = strndup(buffer + matches[10].rm_so, matches[10].rm_eo - matches[10].rm_so);
idc = strtol(temp, NULL, 16);
free(temp);
temp = strndup(buffer + matches[11].rm_so, matches[11].rm_eo - matches[11].rm_so);
ul1 = strtol(temp, NULL, 16);
free(temp);
temp = strndup(buffer + matches[12].rm_so, matches[12].rm_eo - matches[12].rm_so);
udc = strtol(temp, NULL, 16);
free(temp);
temp = strndup(buffer + matches[13].rm_so, matches[13].rm_eo - matches[13].rm_so);
sys = strtol(temp, NULL, 16);
free(temp);
// Construct the query according to active solarmax
sprintf(query, "INSERT INTO %s%d (kdy, kmt, kyr, kt0, tnf, tkk, pac, prl, il1, idc, ul1, udc, sys) VALUES (%d, %d, %d, %d, %d, %d, %d, %d, %d, %d, %d, %d, %d);", dbtabprefix, active_max, kdy, kmt, kyr, kt0, tnf, tkk, pac, prl, il1, idc, ul1, udc, sys);
if (DEBUG) {
sprintf(buffer, "Executing query: %s", query);
debug_entry(buffer);
}
// Execute the query to write the data into db
mysql_query(connection, query);
if (mysql_errno(connection))
error_exit(mysql_error(connection));
}
// Get the current time
time_t stop_time = time(NULL);
// Wait for the specified number of seconds - calc duration - 1
if (DEBUG)
debug_entry("Waiting for about 1 minute ...");
sleep(log_interval + start_time - stop_time -1 );
// Add a busy-loop for the last second to make sure we are perfectly accurate
while (time(NULL) < start_time + log_interval) usleep(99999);
}
}
return 0;
}
Dazu gehört noch die sollog.conf:
- Code: Alles auswählen
# Settings for the Solarmax Watcher
# defaults are shown in parentheses
## Global settings of the logger
# Debug? (0)
Debug=1
# Interval to read the values of the inverter (60)
Loginterval=60
# Interval to wait for inverters answer (200)
Waitinterval=200
## MySQL settings
# Hostname which is running the MySQL server (localhost)
DBhost=localhost
# Name of the MySQL DB for the Solarmax logger (solarmax)
DBname=solarmax
# Tablename prefix (log)
DBtabprefix=log
# DB user to write the values solarmax-DB (solaruser)
DBuser=solaruser
# Password for the DB user (userpassword)
DBpass=userpassword
## Inverter settings
# IP-address or hostname of the inverter connected to the LAN (192.168.178.35)
Hostname=192.168.178.35
# IP-Port of the inverter (12345)
Hostport=12345
# Number of Solarmax inverters in your array (1)
NumberOfInverters=2
Die Abfrage der Deltas geht mit den Kommandos nach diesem Thread:
datenlogger-f5/delta-si-auslesen-hier-kommandos-t62957.html
Es muss dann vom Programm her 12 oder 13 mal ein Kommando an den Wechselrichter geschickt werden, damit man die einzelnen Werte erhält.
Die Werte müssen dann passend konvertiert werden.
Diese müssen dann nach zagibus Methode in der Mysql - Datenbank gespeichert werden.
Die Darstellung übernimmt dann der SolarMax - Visualizer wie er schon vorhanden ist.
Die Verbindung zum Wechselrichter kann man mit der Software von Delta testen:
http://www.solar-inverter.com/eu/de/474.htm
Soweit der Plan.
Es ist zweckmässig, sich einen PC mit Ubuntu herzurichten.
Dann braucht man neben der Dockstar noch einen 2- oder 4 GB USB- Stick.
Auf dem findet der Debian Squeeze mit dem Logger seinen Platz.
Die Dockstar kann man mit folgender Anleitung mit dem Debian versehen:
http://streamboard.gmc.to/wiki/index.ph ... stallieren
Aber Achtung:
In der etc/network/interfaces
ist ein kleiner Bug versteckt:
nach auto lo steht da eth0.
Das muss weg. Sollte dann so etwa aussehen:
- Code: Alles auswählen
## Loopback
auto lo
iface lo inet loopback
## static
iface eth0 inet static
address 195.211.6.17
broadcast 195.211.6.255
gateway 195.211.6.1
netmask 255.255.255.0
Natürlich die IPs auf eigene Verhältnisse anpassen.
Ausserdem hat sich der Squeeze bei mir nach Jeffs Anleitung nicht installieren lassen.
Das muss man mit einer kleinen Änderung eines anderen Users machen:
- Code: Alles auswählen
cd /tmp
wget http://dev.shyd.de/dockstar/dockstar.debian-squeeze.sh
chmod +x dockstar.debian-squeeze.sh
export PATH=$PATH:/usr/sbin:/sbin
./dockstar.debian-squeeze.sh
