on working

Author: gunlee01

pom.xml

@@ -44,4 +44,30 @@
         </dependency>
     </dependencies>
 
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-dependency-plugin</artifactId>
+                <executions>
+                    <execution>
+                        <id>copy-dependencies</id>
+                        <phase>prepare-package</phase>
+                        <goals>
+                            <goal>copy-dependencies</goal>
+                        </goals>
+                        <configuration>
+                            <outputDirectory>${project.build.directory}/lib</outputDirectory>
+                            <overWriteReleases>false</overWriteReleases>
+                            <overWriteSnapshots>false</overWriteSnapshots>
+                            <overWriteIfNewer>true</overWriteIfNewer>
+                            <includeScope>runtime</includeScope>
+                        </configuration>
+                    </execution>
+                </executions>
+            </plugin>
+        </plugins>
+
+    </build>
+
 </project>

scouter-plugin-server-influxdb.iml

@@ -5,6 +5,7 @@
     <output-test url="file://$MODULE_DIR$/target/test-classes" />
     <content url="file://$MODULE_DIR$">
       <sourceFolder url="file://$MODULE_DIR$/src/test/java" isTestSource="true" />
+      <sourceFolder url="file://$MODULE_DIR$/src/main/java" isTestSource="false" />
       <excludeFolder url="file://$MODULE_DIR$/target" />
     </content>
     <orderEntry type="inheritedJdk" />

src/main/java/scouter/plugin/server/influxdb/InfluxdbPlugin.java

@@ -1,18 +1,60 @@
 package scouter.plugin.server.influxdb;
 
+import org.influxdb.dto.Point;
+import scouter.lang.TimeTypeEnum;
 import scouter.lang.pack.PerfCounterPack;
 import scouter.lang.plugin.PluginConstants;
 import scouter.lang.plugin.annotation.ServerPlugin;
+import scouter.lang.value.Value;
 import scouter.server.Configure;
 
+import java.util.Map;
+import java.util.concurrent.TimeUnit;
+
 /**
  * @author Gun Lee (gunlee01@gmail.com) on 2016. 3. 29.
  */
 public class InfluxdbPlugin {
     Configure conf = Configure.getInstance();
 
+    final String confMeasurement = "ext_plugin_influxdb_measurement";
+    final String confTagObj      = "ext_plugin_influxdb_tag_obj";
+    final String confTagTimeType = "ext_plugin_influxdb_tag_timetype";
+
+    final String confMeasurementDefault = "counter";
+    final String confTagObjDefault      = "obj";
+    final String confTagTimeTypeDefault = "timetype";
+
     @ServerPlugin(PluginConstants.PLUGIN_SERVER_COUNTER)
     public void counter(PerfCounterPack pack) {
+        String measurementName = conf.getValue(confMeasurement, confMeasurementDefault);
+        String objTagName = conf.getValue(confTagObj, confTagObjDefault);
+        String timeTypeTagName = conf.getValue(confTagTimeType, confTagTimeTypeDefault);
+
+        try {
+            Point.Builder builder = Point.measurement(measurementName)
+                    .time(pack.time, TimeUnit.MILLISECONDS)
+                    .tag(objTagName, pack.objName)
+                    .tag(timeTypeTagName, TimeTypeEnum.getString(pack.timetype));
+
+            Map<String, Value> dataMap = pack.data.toMap();
+            for (Map.Entry<String, Value> field : dataMap.entrySet()) {
+                Value valueOrigin = field.getValue();
+                if (valueOrigin == null) {
+                    continue;
+                }
+                Object value = valueOrigin.toJavaObject();
+                String key = field.getKey();
+                builder.field(key, value);
+            }
+
+            Point point = builder.build();
+            String line = point.lineProtocol();
+
+            System.out.println(line);
 
+        } catch (Exception e) {
+            e.getMessage();
+        }
     }
 }