Charmed Quark Systems, Ltd. - Support Forums and Community

Pages: 1 2

I use Grafana and InfluxDB at work, and it's fairly quick and easy to set up for graphing time-series data (especially if you have a Docker host, which I do). ┬áI decided it might be interesting to try integrating it with CQC. ┬áThere are a few┬áways to get data in, and one of the more straightforward methods is by doing an HTTP POST. ┬áHere is an example of┬áhow you would do it using curl:

Code:
curl -i -XPOST 'http://localhost:8086/write?db=mydb' --data-binary 'cpu_load_short,host=server01,region=us-west value=0.64 1434055562000000000'

You can also log multiple points with one call, which is much more efficient:

Code:
curl -i -XPOST 'http://localhost:8086/write?db=mydb' --data-binary 'cpu_load_short,host=server02 value=0.67

cpu_load_short,host=server02,region=us-west value=0.55 1422568543702900257

cpu_load_short,direction=in,host=server01,region=us-west value=2.0 1422568543702900257'

I did a bit of searching in the forum but didn't immediately find anything. ┬áIs there a way to do something like┬áthis in CQC? ┬áIf so, it would be fun to write a CML macro that runs periodically and logs various CQC device properties for graphing.

The CML HTTPClient will do POSTs - http://www.charmedquark.com/Web2/ExtCont...Client.htm

Perfect - thanks for the pointer, and the fast response!┬á Smile

Here's an example:

Code:
Method LoadURL([In] IPEndPoint ip, [In] String strURL, [In] String strData, [In] Card4 c4Timeout, 

 ┬á ┬á[In] Boolean bParse, [In] Boolean bPost) Returns Boolean

 ┬á ┬áBegin

 ┬á ┬á ┬á ┬áLocals=

 ┬á ┬á ┬á ┬á ┬á ┬áString ┬á ┬á ┬ástrContType;

 ┬á ┬á ┬á ┬á ┬á ┬áString ┬á ┬á ┬ástrRepText;

 ┬á ┬á ┬á ┬á ┬á ┬áString ┬á ┬á ┬ástrTemp;

 ┬á ┬á ┬á ┬á ┬á ┬áString ┬á ┬á ┬ástrAccept("*/*");

 ┬á ┬á ┬á ┬á ┬á ┬áLinesList ┬á lstHeader;

 ┬á ┬á ┬á ┬á ┬á ┬áLinesList ┬á lstNull;

 ┬á ┬á ┬á ┬á ┬á ┬áCard4 ┬á ┬á ┬á c4Count(0);

 ┬á ┬á ┬á ┬á ┬á ┬áCard4 ┬á ┬á ┬á c4RetCount;

 ┬á ┬á ┬á ┬á ┬á ┬áCard4 ┬á ┬á ┬á c4RetVal;

 ┬á ┬á ┬á ┬á ┬á ┬áCard4 ┬á ┬á ┬á c4BufSize;

 ┬á ┬á ┬á ┬á ┬á ┬áURL ┬á ┬á ┬á ┬á urlLoc;

 ┬á ┬á ┬á ┬á ┬á ┬áMemBuf ┬á ┬á ┬ábufTemp;

 ┬á ┬á ┬á ┬á ┬á ┬áHTTPClient ┬áhttp;

 ┬á ┬á ┬á ┬á ┬á ┬áBoolean ┬á ┬á bData(False);

 ┬á ┬á ┬á ┬á ┬á ┬áDataSrc ┬á ┬á dataTemp;

 ┬á ┬á ┬á ┬áEndLocals;

 ┬á ┬áTry

 ┬á ┬á ┬á ┬á// Determine if there is content

 ┬á ┬á ┬á ┬áIf (strData != "")

 ┬á ┬á ┬á ┬á ┬á ┬ábData := True;

 ┬á ┬á ┬á ┬á ┬á ┬ác4Count := strData.GetLength();

 ┬á ┬á ┬á ┬á ┬á ┬ábufTemp.ImportString(strData, c4Count);

 ┬á ┬á ┬á ┬áEndIf;

 ┬á ┬á ┬á ┬ác4BufSize := bufTemp.GetMaxSize(); 

 ┬á ┬á ┬á ┬ástrAccept := "text";

 ┬á ┬á ┬á ┬ástrRepText := "blah"; ┬á 

 ┬á ┬á ┬á ┬á// Setup DataSrc

 ┬á ┬á ┬á ┬ádataTemp.TCPSetup(ip, False); ┬á ┬á 

 ┬á ┬á ┬á ┬á// Set the URL

 ┬á ┬á ┬á ┬áurlLoc.Set(strURL, FQTypes.DontCare); 

 ┬á ┬á ┬á ┬áLogIt(LogMsgs.URL, "LoadURL", strURL, c4Timeout, bPost);

 ┬á ┬á ┬á ┬áIf (bPost)

 ┬á ┬á ┬á ┬á ┬á ┬á// Send the HTTP POST

 ┬á ┬á ┬á ┬á ┬á ┬áhttp.SendPOST2(urlLoc, c4Timeout, "CQC", "*/*", strRepText,

 ┬á ┬á ┬á ┬á ┬á ┬á ┬á ┬á ┬á ┬á ┬á ┬á ┬á ┬á ┬álstHeader, strAccept, bufTemp, c4Count, bData, lstNull);

 ┬á ┬á ┬á ┬áElse

 ┬á ┬á ┬á ┬á ┬á ┬ác4RetVal := http.SendRUGET(urlLoc, c4Timeout, "CQC", "*/*", strRepText,

 ┬á ┬á ┬á ┬á ┬á ┬á ┬á ┬á ┬á ┬álstHeader, strAccept, bufTemp, c4Count, False, lstNull, dataTemp);

 ┬á ┬á ┬á ┬á ┬á ┬ádataTemp.Close();

 ┬á ┬á ┬á ┬áEndIf;

 ┬á ┬á ┬á ┬áIf (!bParse)

 ┬á ┬á ┬á ┬á ┬á ┬á// Skip parsing response

 ┬á ┬á ┬á ┬á ┬á ┬áReturn True;

 ┬á ┬á ┬á ┬áEndIf;

 ┬á ┬á ┬á ┬áIf (c4Count > 0)

 ┬á ┬á ┬á ┬á ┬á ┬áLogIt(LogMsgs.URLResp1, "LoadURL", strURL, c4Count, "");

 ┬á ┬á ┬á ┬á ┬á ┬ábufTemp.ExportString(strTemp, c4Count);

 ┬á ┬á ┬á ┬á ┬á ┬ám_strConfig.Append(strTemp);

 ┬á ┬á ┬á ┬áEndIf;

 ┬á ┬á ┬á ┬á

 ┬á ┬á ┬á ┬áLogIt(LogMsgs.URLResp2, "LoadURL", m_strConfig,"","");

 ┬á ┬á ┬á ┬á

 ┬á ┬á ┬á ┬áIf (ParseJSON())

 ┬á ┬á ┬á ┬á ┬á Return True;

 ┬á ┬á ┬á ┬áElse

 ┬á ┬á ┬á ┬á ┬á LogIt(LogMsgs.URLParseErr, "LoadURL", "","","");

 ┬á ┬á ┬á ┬á ┬á Return False;

 ┬á ┬á ┬á ┬áEndIf;

 ┬á ┬áEndTry;

 ┬á ┬áCatch

 ┬á ┬á ┬á ┬áLogIt(LogMsgs.Exception, "LoadURL-Exception", $Exception.GetErrorText(), "", "");

 ┬á ┬á ┬á ┬áReturn False;

 ┬á ┬áEndCatch;

EndMethod;

I've done basically no web development, so I apologize if this is a newbie question, but I could use a bit of help on exactly how to construct the SendPOST2 call. ┬áI have a test macro written, and I think I have most everything set correctly, but I'm not seeing anything get written to the database.

Here is an example of an actual command I sent using curl (which successfully wrote to the database):

Code:
curl -i -XPOST 'http://192.168.59.177:8086/write?db=cqc' --data-binary 'temperature,thermostat=outdoor value=50'

For the SendPOST2 call, I set the┬áURL parameter to┬á"http://192.168.59.177:8086/write?db=cqc" and the memory buffer to┬á"temperature,thermostat=theater value=63". ┬áIs this correct?

You'd have to create a URL object and set it to that URL. For the memory buffer, yeh, as in the example above, just import it into the memory buffer to convert to bytes. That will tell you the number of bytes it put into the buffer, which is the number of bytes to indicate as the outgoing body size.

The --data-binary may translate into some MIME type that you will need to send as the outgoing data type.

This is what I have so far:

Code:
┬á ┬áMethod Start() Returns Int4

 ┬á ┬áBegin

 ┬á ┬á ┬á ┬áLocals=

 ┬á ┬á ┬á ┬á ┬á ┬áString ┬á ┬á ┬ástrContType;

 ┬á ┬á ┬á ┬á ┬á ┬áString ┬á ┬á ┬ástrRepText;

 ┬á ┬á ┬á ┬á ┬á ┬áString ┬á ┬á ┬ástrTemp;

 ┬á ┬á ┬á ┬á ┬á ┬áString ┬á ┬á ┬ástrAccept("*/*");

 ┬á ┬á ┬á ┬á ┬á ┬áLinesList ┬á lstHeader;

 ┬á ┬á ┬á ┬á ┬á ┬áLinesList ┬á lstNull;

 ┬á ┬á ┬á ┬á ┬á ┬áCard4 ┬á ┬á ┬á c4Count(0);

 ┬á ┬á ┬á ┬á ┬á ┬áCard4 ┬á ┬á ┬á c4RetCount;

 ┬á ┬á ┬á ┬á ┬á ┬áCard4 ┬á ┬á ┬á c4RetVal;

 ┬á ┬á ┬á ┬á ┬á ┬áCard4 ┬á ┬á ┬á c4BufSize;

 ┬á ┬á ┬á ┬á ┬á ┬áURL ┬á ┬á ┬á ┬á urlLoc;

 ┬á ┬á ┬á ┬á ┬á ┬áMemBuf ┬á ┬á ┬ábufTemp;

 ┬á ┬á ┬á ┬á ┬á ┬áHTTPClient ┬áhttp;

 ┬á ┬á ┬á ┬á ┬á ┬áBoolean ┬á ┬á bData(False);

 ┬á ┬á ┬á ┬á ┬á ┬áDataSrc ┬á ┬á dataTemp;

 ┬á ┬á ┬á ┬á ┬á ┬áString ┬á ┬á ┬ástrData;

 ┬á ┬á ┬á ┬áEndLocals;

 ┬á ┬á ┬á ┬áurlLoc.Set("http://192.168.59.177:8086/write?db=cqc", FQTypes.DontCare);

 ┬á ┬á ┬á ┬ástrData := "temperature,thermostat=theater value=63";

 ┬á ┬á ┬á ┬ác4Count := strData.GetLength();

 ┬á ┬á ┬á ┬ábufTemp.ImportString(strData, c4Count);

 ┬á ┬á ┬á ┬áhttp.SendPOST2(urlLoc, 5, "CQC", "*/*", strRepText, lstHeader, strAccept, bufTemp, c4Count, bData, lstNull);

 ┬á ┬á ┬á ┬áReturn 0;

 ┬á ┬áEndMethod;

I wondered about the binary bit. ┬áI'll have to do some more research, as I don't know what that does for curl.

From the curl man page:

--data-binary <data>

(HTTP) This posts data exactly as specified with no extra processing whatsoever.

Based on that, it seems like I shouldn't need to do anything special with SendPOST2, should I?

That looks reasonable.

If it's literally sending binary data, then you should probably set the outgoing MIME type to "application/octet-stream".

Pages: 1 2

Charmed Quark Systems, Ltd. - Support Forums and Community

dlmorgan999

wuench

dlmorgan999

wuench

dlmorgan999

Dean Roddey

dlmorgan999

dlmorgan999

Dean Roddey

Dean Roddey