org.influxdb.dto.Point.lineProtocol()方法的使用及代码示例

x33g5p2x  于2022-01-26 转载在 其他  
字(11.6k)|赞(0)|评价(0)|浏览(184)

本文整理了Java中org.influxdb.dto.Point.lineProtocol()方法的一些代码示例，展示了Point.lineProtocol()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Point.lineProtocol()方法的具体详情如下：
包路径：org.influxdb.dto.Point
类名称：Point
方法名：lineProtocol

Point.lineProtocol介绍

[英]calculate the lineprotocol entry for a single Point. Documentation is WIP : https://github.com/influxdb/influxdb/pull/2997 https://github.com/influxdb/influxdb/blob/master/tsdb/README.md
[中]计算单个点的lineprotocol条目。文件是WIP：https://github.com/influxdb/influxdb/pull/2997 https://github.com/influxdb/influxdb/blob/master/tsdb/README.md

代码示例

代码示例来源：origin: apache/incubator-gobblin

  1. @Override
  2. public void write(BatchPoints batchPoints) {
  3.  for (Point point : batchPoints.getPoints()) {
  4.   write(point.lineProtocol());
  5.  }
  6. }

代码示例来源：origin: influxdata/influxdb-java

  1. /**
  2.  * calculate the lineprotocol entry for a single Point.
  3.  *
  4.  * Documentation is WIP : https://github.com/influxdb/influxdb/pull/2997
  5.  *
  6.  * https://github.com/influxdb/influxdb/blob/master/tsdb/README.md
  7.  *
  8.  * @return the String without newLine.
  9.  */
  10. public String lineProtocol() {
  11.  return lineProtocol(null);
  12. }

代码示例来源：origin: influxdata/influxdb-java

  1. /**
  2.  * calculate the lineprotocol for all Points.
  3.  *
  4.  * @return the String with newLines.
  5.  */
  6. public String lineProtocol() {
  7.  StringBuilder sb = new StringBuilder();
  8.  for (Point point : this.points) {
  9.   sb.append(point.lineProtocol(this.precision)).append("\n");
  10.  }
  11.  return sb.toString();
  12. }

代码示例来源：origin: influxdata/influxdb-java

  1. /**
  2.  * {@inheritDoc}
  3.  */
  4. @Override
  5. public void write(final int udpPort, final Point point) {
  6.  if (this.batchEnabled.get()) {
  7.   UdpBatchEntry batchEntry = new UdpBatchEntry(point, udpPort);
  8.   this.batchProcessor.put(batchEntry);
  9.  } else {
  10.   this.write(udpPort, point.lineProtocol());
  11.   this.unBatchedCount.increment();
  12.  }
  13.  this.writeCount.increment();
  14. }

代码示例来源：origin: influxdata/influxdb-java

  1. udpPortToBatchPoints.put(udpPort, batchPoints);
  2. udpPortToBatchPoints.get(udpPort).add(point.lineProtocol());

代码示例来源：origin: org.influxdb/influxdb-java

  1. /**
  2.  * calculate the lineprotocol entry for a single Point.
  3.  *
  4.  * Documentation is WIP : https://github.com/influxdb/influxdb/pull/2997
  5.  *
  6.  * https://github.com/influxdb/influxdb/blob/master/tsdb/README.md
  7.  *
  8.  * @return the String without newLine.
  9.  */
  10. public String lineProtocol() {
  11.  return lineProtocol(null);
  12. }

代码示例来源：origin: org.influxdb/influxdb-java

  1. /**
  2.  * calculate the lineprotocol for all Points.
  3.  *
  4.  * @return the String with newLines.
  5.  */
  6. public String lineProtocol() {
  7.  StringBuilder sb = new StringBuilder();
  8.  for (Point point : this.points) {
  9.   sb.append(point.lineProtocol(this.precision)).append("\n");
  10.  }
  11.  return sb.toString();
  12. }

代码示例来源：origin: com.remondis.limbus/limbus-monitoring-influx

  1. public static void sendData(Point point, InetAddress host, int port) throws IOException {
  2.  sendData(point.lineProtocol(), host, port);
  3. }

代码示例来源：origin: org.influxdb/influxdb-java

  1. /**
  2.  * {@inheritDoc}
  3.  */
  4. @Override
  5. public void write(final int udpPort, final Point point) {
  6.  if (this.batchEnabled.get()) {
  7.   UdpBatchEntry batchEntry = new UdpBatchEntry(point, udpPort);
  8.   this.batchProcessor.put(batchEntry);
  9.  } else {
  10.   this.write(udpPort, point.lineProtocol());
  11.   this.unBatchedCount.increment();
  12.  }
  13.  this.writeCount.increment();
  14. }

代码示例来源：origin: NovatecConsulting/JMeter-InfluxDB-Writer

  1. @Override
  2. public void setupTest(BackendListenerContext context) throws Exception {
  3.   testName = context.getParameter(KEY_TEST_NAME, "Test");
  4.   File exportFile = new File(context.getParameter(KEY_FILE_PATH, "influxDBExport.txt"));
  5.   if (exportFile.getParentFile() != null && !exportFile.getParentFile().exists()) {
  6.     exportFile.getParentFile().mkdirs();
  7.   }
  8.   if (exportFile.exists()) {
  9.     exportFile.delete();
  10.     boolean created = exportFile.createNewFile();
  11.     if (!created) {
  12.       throw new RuntimeException("Export file could not be created!");
  13.     }
  14.   }
  15.   exportFileWriter = new BufferedWriter(new FileWriter(exportFile));
  16.   Point startPoint = Point.measurement(TestStartEndMeasurement.MEASUREMENT_NAME).time(System.currentTimeMillis(), TimeUnit.MILLISECONDS)
  17.       .tag(TestStartEndMeasurement.Tags.TYPE, TestStartEndMeasurement.Values.STARTED).tag(TestStartEndMeasurement.Tags.TEST_NAME, testName).build();
  18.   exportFileWriter.append(startPoint.lineProtocol());
  19.   exportFileWriter.newLine();
  20.   parseSamplers(context);
  21.   scheduler = Executors.newScheduledThreadPool(1);
  22.   scheduler.scheduleAtFixedRate(this, 1, 1, TimeUnit.SECONDS);
  23. }

代码示例来源：origin: org.influxdb/influxdb-java

  1. udpPortToBatchPoints.put(udpPort, batchPoints);
  2. udpPortToBatchPoints.get(udpPort).add(point.lineProtocol());

代码示例来源：origin: NovatecConsulting/JMeter-InfluxDB-Writer

  1. @Override
  2. public void teardownTest(BackendListenerContext context) throws Exception {
  3.   LOGGER.info("Shutting down influxDB scheduler...");
  4.   scheduler.shutdown();
  5.   addVirtualUsersMetrics(0, 0, 0, 0, JMeterContextService.getThreadCounts().finishedThreads);
  6.   Point endPoint = Point.measurement(TestStartEndMeasurement.MEASUREMENT_NAME).time(System.currentTimeMillis(), TimeUnit.MILLISECONDS)
  7.       .tag(TestStartEndMeasurement.Tags.TYPE, TestStartEndMeasurement.Values.FINISHED).tag(TestStartEndMeasurement.Tags.TEST_NAME, testName).build();
  8.   exportFileWriter.append(endPoint.lineProtocol());
  9.   exportFileWriter.newLine();
  10.   
  11.   try {
  12.     scheduler.awaitTermination(30, TimeUnit.SECONDS);
  13.     LOGGER.info("influxDB scheduler terminated!");
  14.   } catch (InterruptedException e) {
  15.     LOGGER.error("Error waiting for end of scheduler");
  16.   }
  17.   samplersToFilter.clear();
  18.   exportFileWriter.close();
  19.   super.teardownTest(context);
  20. }

代码示例来源：origin: inspectIT/inspectIT

  1. @Test
  2.   public void mustToCallToInsertDBDao() {
  3.     Builder builder = Point.measurement("test").addField("test", 1).time(1, TimeUnit.MILLISECONDS);
  4.     when(diagnosisCmrConfiguration.problemOccurrencePointBuilder.getBuilder(problemOccurrence)).thenReturn(builder);
  5.     diagnosisCmrConfiguration.accept(problemOccurrence);
  6.     ArgumentCaptor<Point> pointCaptor = ArgumentCaptor.forClass(Point.class);
  7.     verify(diagnosisCmrConfiguration.influxDBDao).insert(pointCaptor.capture());
  8.     assertThat(pointCaptor.getValue().lineProtocol(), is(builder.build().lineProtocol()));
  9.   }
  10. }

代码示例来源：origin: NovatecConsulting/JMeter-InfluxDB-Writer

  1. /**
  2.    * Write thread metrics.
  3.    */
  4.   private void addVirtualUsersMetrics(int minActiveThreads, int meanActiveThreads, int maxActiveThreads, int startedThreads, int finishedThreads) {
  5.     Builder builder = Point.measurement(VirtualUsersMeasurement.MEASUREMENT_NAME).time(System.currentTimeMillis(), TimeUnit.MILLISECONDS);
  6.     builder.addField(VirtualUsersMeasurement.Fields.MIN_ACTIVE_THREADS, minActiveThreads);
  7.     builder.addField(VirtualUsersMeasurement.Fields.MAX_ACTIVE_THREADS, maxActiveThreads);
  8.     builder.addField(VirtualUsersMeasurement.Fields.MEAN_ACTIVE_THREADS, meanActiveThreads);
  9.     builder.addField(VirtualUsersMeasurement.Fields.STARTED_THREADS, startedThreads);
  10.     builder.addField(VirtualUsersMeasurement.Fields.FINISHED_THREADS, finishedThreads);
  11.     try {
  12.       exportFileWriter.append(builder.build().lineProtocol());
  13.       exportFileWriter.newLine();
  14.     } catch (IOException e) {
  15.       throw new RuntimeException(e);
  16.     }
  17.   }
  18. }

代码示例来源：origin: inspectIT/inspectIT

  1. @Test
  2. public void jmxNumeric() {
  3.   JmxSensorValueData data = new JmxSensorValueData();
  4.   data.setValue("1");
  5.   when(influxDBDao.isConnected()).thenReturn(true);
  6.   doReturn(Collections.singleton(JmxSensorValueData.class)).when(pointBuilder).getDataClasses();
  7.   when(pointBuilder.createBuilders(data)).thenReturn(Collections.singleton(builder));
  8.   processor = new InfluxProcessor(influxDBDao, Collections.<IPointBuilder<DefaultData>> singletonList(pointBuilder));
  9.   processor.process(data, entityManager);
  10.   verify(influxDBDao).isConnected();
  11.   ArgumentCaptor<Point> pointCaptor = ArgumentCaptor.forClass(Point.class);
  12.   verify(influxDBDao).insert(pointCaptor.capture());
  13.   assertThat(pointCaptor.getValue().lineProtocol(), is(builder.build().lineProtocol()));
  14.   verifyZeroInteractions(entityManager);
  15. }

代码示例来源：origin: inspectIT/inspectIT

  1. @Test
  2. public void processed() {
  3.   InvocationSequenceData invocationData = new InvocationSequenceData();
  4.   when(influxDBDao.isConnected()).thenReturn(true);
  5.   doReturn(Collections.singleton(InvocationSequenceData.class)).when(pointBuilder).getDataClasses();
  6.   when(pointBuilder.createBuilders(invocationData)).thenReturn(Collections.singleton(builder));
  7.   processor = new InfluxProcessor(influxDBDao, Collections.<IPointBuilder<DefaultData>> singletonList(pointBuilder));
  8.   processor.process(invocationData, entityManager);
  9.   verify(influxDBDao).isConnected();
  10.   ArgumentCaptor<Point> pointCaptor = ArgumentCaptor.forClass(Point.class);
  11.   verify(influxDBDao).insert(pointCaptor.capture());
  12.   assertThat(pointCaptor.getValue().lineProtocol(), is(builder.build().lineProtocol()));
  13.   verifyZeroInteractions(entityManager);
  14. }

代码示例来源：origin: inspectIT/inspectIT

  1. @Test
  2. public void timerCharting() {
  3.   TimerData data = new TimerData();
  4.   data.setCharting(true);
  5.   when(influxDBDao.isConnected()).thenReturn(true);
  6.   doReturn(Collections.singleton(TimerData.class)).when(pointBuilder).getDataClasses();
  7.   when(pointBuilder.createBuilders(data)).thenReturn(Collections.singleton(builder));
  8.   processor = new InfluxProcessor(influxDBDao, Collections.<IPointBuilder<DefaultData>> singletonList(pointBuilder));
  9.   processor.process(data, entityManager);
  10.   verify(influxDBDao).isConnected();
  11.   ArgumentCaptor<Point> pointCaptor = ArgumentCaptor.forClass(Point.class);
  12.   verify(influxDBDao).insert(pointCaptor.capture());
  13.   assertThat(pointCaptor.getValue().lineProtocol(), is(builder.build().lineProtocol()));
  14.   verifyZeroInteractions(entityManager);
  15. }

代码示例来源：origin: smartcat-labs/cassandra-diagnostics

  1. private ByteBuffer lineProtocol(Measurement measurement) {
  2.     try {
  3.       final Point.Builder builder = Point.measurement(measurement.name());
  4.       builder.time(measurement.time(), measurement.timeUnit());
  6.       builder.tag(measurement.tags());
  7.       builder.tag("type", measurement.type().toString());
  9.       if (measurement.isSimple()) {
  10.         builder.addField("value", measurement.getValue());
  11.       }
  13.       for (Map.Entry<String, String> field : measurement.fields().entrySet()) {
  14.         builder.addField(field.getKey(), field.getValue());
  15.       }
  16.       Charset charset = StandardCharsets.UTF_8;
  17.       CharsetEncoder encoder = charset.newEncoder();
  18.       return encoder.encode(CharBuffer.wrap(builder.build().lineProtocol().concat("\r\n").toCharArray()));
  19.     } catch (Exception e) {
  20.       logger.warn("Failed to send report to influx", e);
  21.       return null;
  22.     }
  23.   }
  24. }

代码示例来源：origin: NovatecConsulting/JMeter-InfluxDB-Writer

  1. /**
  2.  * Processes sampler results.
  3.  */
  4. public void handleSampleResults(List<SampleResult> sampleResults, BackendListenerContext context) {
  5.   for (SampleResult sampleResult : sampleResults) {
  6.     getUserMetrics().add(sampleResult);
  7.     if ((null != regexForSamplerList && sampleResult.getSampleLabel().matches(regexForSamplerList)) || samplersToFilter.contains(sampleResult.getSampleLabel())) {
  8.       Point point = Point.measurement(RequestMeasurement.MEASUREMENT_NAME).time(System.currentTimeMillis(), TimeUnit.MILLISECONDS)
  9.           .tag(RequestMeasurement.Tags.REQUEST_NAME, sampleResult.getSampleLabel()).addField(RequestMeasurement.Fields.ERROR_COUNT, sampleResult.getErrorCount())
  10.           .addField(RequestMeasurement.Fields.RESPONSE_TIME, sampleResult.getTime()).build();
  11.       try {
  12.         exportFileWriter.append(point.lineProtocol());
  13.         exportFileWriter.newLine();
  14.       } catch (IOException e) {
  15.         throw new RuntimeException(e);
  16.       }
  17.     }
  18.   }
  19. }

代码示例来源：origin: org.apache.camel/camel-influxdb

  1. private void doInsert(Exchange exchange, String dataBaseName, String retentionPolicy) throws InvalidPayloadException {
  2.   if (!endpoint.isBatch()) {
  3.     Point p = exchange.getIn().getMandatoryBody(Point.class);
  4.     try {
  5.       LOG.debug("Writing point {}", p.lineProtocol());
  6.       
  7.       if (!connection.databaseExists(dataBaseName)) {
  8.         LOG.debug("Database {} doesn't exist. Creating it...", dataBaseName);
  9.         connection.createDatabase(dataBaseName);
  10.       }
  11.       connection.write(dataBaseName, retentionPolicy, p);
  12.     } catch (Exception ex) {
  13.       exchange.setException(new CamelInfluxDbException(ex));
  14.     }
  15.   } else {
  16.     BatchPoints batchPoints = exchange.getIn().getMandatoryBody(BatchPoints.class);
  17.     try {
  18.       LOG.debug("Writing BatchPoints {}", batchPoints.lineProtocol());
  19.       connection.write(batchPoints);
  20.     } catch (Exception ex) {
  21.       exchange.setException(new CamelInfluxDbException(ex));
  22.     }
  23.   }
  24. }

内容来源于网络，如有侵权，请联系作者删除！

Point

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com