added generate sensor config ing

This commit is contained in:
snoop 2017-08-29 16:43:22 +09:00
parent f1dde3b127
commit cff48e2271
11 changed files with 517 additions and 1 deletions

View File

@ -124,6 +124,12 @@
<version>1.0.0-SNAPSHOT</version>
</dependency>
<dependency>
<groupId>com.loafle.overflow</groupId>
<artifactId>crawler</artifactId>
<version>1.0.0-SNAPSHOT</version>
</dependency>
</dependencies>

View File

@ -28,5 +28,7 @@ public interface InfraDAO extends JpaRepository<Infra, Long> {
@Query("SELECT DISTINCT i.target FROM INFRA i WHERE i.probe IN (:probeList)")
List<Target> findAllTargetByProbeList(@Param("probeList") List<Probe> probeList);
Infra findByTarget(Target target);
// List<Infra> findAllByProbe(List<Probe> probeList);
}

View File

@ -60,5 +60,9 @@ public class InfraService {
// return null;
}
public Infra readByTarget(Target target) {
return this.infraDAO.findByTarget(target);
}
}

View File

@ -0,0 +1,18 @@
package com.loafle.overflow.module.meta.dao;
import com.loafle.overflow.module.meta.model.MetaCrawler;
import com.loafle.overflow.module.meta.model.MetaSensorItemKey;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.stereotype.Repository;
import java.util.List;
/**
* Created by snoop on 17. 8. 29.
*/
@Repository
public interface MetaSensorItemKeyDAO extends JpaRepository<MetaSensorItemKey, Long> {
// @Query("SELECT msik.item.id, msik.key from MetaSensorItemKey msik WHERE msik.crawler.id = (:metaCrawler.id)")
List<MetaSensorItemKey> findAllByCrawler(MetaCrawler metaCrawler);
}

View File

@ -0,0 +1,66 @@
package com.loafle.overflow.module.meta.model;
import javax.persistence.*;
import java.util.Date;
/**
* Created by snoop on 17. 8. 29.
*/
@Entity
@Table(name = "META_SENSOR_ITEM_KEY", schema = "public")
public class MetaSensorItemKey {
private long id;
private MetaSensorItem item;
private String key;
private MetaCrawler crawler;
private Date createDate;
@Id
@GeneratedValue(strategy= GenerationType.IDENTITY)
public long getId() {
return id;
}
public void setId(long id) {
this.id = id;
}
@ManyToOne
@JoinColumn(name = "ITEM_ID", nullable = false)
public MetaSensorItem getItem() {
return item;
}
public void setItem(MetaSensorItem item) {
this.item = item;
}
@Column(name = "KEY", nullable = true, length = 100)
public String getKey() {
return key;
}
public void setKey(String key) {
this.key = key;
}
@ManyToOne
@JoinColumn(name = "CRAWLER_ID", nullable = false)
public MetaCrawler getCrawler() {
return crawler;
}
public void setCrawler(MetaCrawler crawler) {
this.crawler = crawler;
}
@Temporal(TemporalType.TIMESTAMP)
@Column(name="CREATE_DATE", nullable = false, columnDefinition = "TIMESTAMP DEFAULT CURRENT_TIMESTAMP", insertable = false, updatable = false)
public Date getCreateDate() {
return createDate;
}
public void setCreateDate(Date createDate) {
this.createDate = createDate;
}
}

View File

@ -0,0 +1,36 @@
package com.loafle.overflow.module.meta.service;
import com.loafle.overflow.module.meta.dao.MetaSensorItemKeyDAO;
import com.loafle.overflow.module.meta.model.MetaCrawler;
import com.loafle.overflow.module.meta.model.MetaSensorItemKey;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
/**
* Created by snoop on 17. 8. 29.
*/
@Service
public class MetaSensorItemKeyService {
@Autowired
private MetaSensorItemKeyDAO metaSensorItemKeyDAO;
public Map<Integer, String> readAllByCrawler(MetaCrawler metaCrawler) {
Map<Integer, String> resultMap = new HashMap<>();
List<MetaSensorItemKey> resultList = this.metaSensorItemKeyDAO.findAllByCrawler(metaCrawler);
for(MetaSensorItemKey oa : resultList) {
resultMap.put(oa.getItem().getId(), oa.getKey());
}
return resultMap;
}
}

View File

@ -2,22 +2,30 @@ package com.loafle.overflow.module.sensor.service;
import com.loafle.overflow.commons.model.PageParams;
import com.loafle.overflow.commons.utils.PageUtil;
import com.loafle.overflow.commons.utils.StringConvertor;
import com.loafle.overflow.crawler.config.*;
import com.loafle.overflow.module.domain.model.Domain;
import com.loafle.overflow.module.infra.model.Infra;
import com.loafle.overflow.module.infra.model.*;
import com.loafle.overflow.module.infra.service.InfraService;
import com.loafle.overflow.module.meta.model.MetaSensorStatus;
import com.loafle.overflow.module.meta.service.MetaSensorItemKeyService;
import com.loafle.overflow.module.probe.model.Probe;
import com.loafle.overflow.module.probe.service.ProbeService;
import com.loafle.overflow.module.sensor.dao.SensorDAO;
import com.loafle.overflow.module.sensor.model.Sensor;
import com.loafle.overflow.module.sensor.model.SensorItem;
import com.loafle.overflow.module.target.model.Target;
import org.codehaus.jackson.map.ObjectMapper;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.domain.Page;
import org.springframework.stereotype.Service;
import javax.transaction.Transactional;
import java.io.IOException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
/**
* Created by insanity on 17. 6. 28.
@ -37,6 +45,11 @@ public class SensorService {
@Autowired
private SensorItemService sensorItemService;
@Autowired
private MetaSensorItemKeyService metaSensorItemKeyService;
private Map<Integer, String> mappingMap = null;
public Sensor regist(Sensor sensor) {
return this.sensorDAO.save(sensor);
}
@ -96,4 +109,130 @@ public class SensorService {
return sensor;
}
public String generateSensorConfig(Sensor sensor) throws IOException {
// Sensor dbSensor = this.sensorDAO.findOne(sensor.getId());
PageParams pageParams = new PageParams();
pageParams.setPageNo(0);
pageParams.setCountPerPage(Integer.MAX_VALUE);
pageParams.setSortCol("id");
pageParams.setSortDirection("descending");
Page<SensorItem> dbItemList = this.sensorItemService.readAllBySensor(sensor, pageParams);
List<SensorItem> sensorItems = dbItemList.getContent();
if(sensorItems.size() <= 0) {
return "";
}
Sensor dbSensor = sensorItems.get(0).getSensor();
Infra infra = this.infraService.readByTarget(dbSensor.getTarget());
// InfraHost infraHost = this.getInfraHost(infra);
com.loafle.overflow.module.infra.model.InfraService infraService = (com.loafle.overflow.module.infra.model.InfraService)infra;
Config config = new Config();
config.setId(String.valueOf(sensor.getId()));
com.loafle.overflow.crawler.config.Target target = new com.loafle.overflow.crawler.config.Target();
Connection connection = new Connection();
connection.setIp(StringConvertor.intToIp(infraService.getHost().getIp()));
connection.setPort(String.valueOf(infraService.getPort()));
connection.setPortType(infraService.getPortType());
connection.setSsl(infraService.isTlsType());
target.setConnection(connection);
Map<String, Object> auth = new HashMap<>();
auth.put("url", "jdbc:mysql://"+StringConvertor.intToIp(infraService.getHost().getIp())+":"+String.valueOf(infraService.getPort()));
auth.put("id", "docker"); // FIXME: Auth Info
auth.put("pw", "qwer5795QWER"); // FIXME: Auth Info
target.setAuth(auth);
config.setTarget(target);
Schedule schedule = new Schedule();
schedule.setInterval("5"); // FIXME: Interval
config.setSchedule(schedule);
Crawler crawler = new Crawler();
crawler.setName(dbSensor.getCrawler().getName());
crawler.setContainer("java_proxy"); // FIXME: if
config.setCrawler(crawler);
if(this.mappingMap == null) {
this.mappingMap = this.metaSensorItemKeyService.readAllByCrawler(dbSensor.getCrawler());
}
Item item = new Item();
Keys keys = null;
List<Keys> keysList = new ArrayList<>();
for(SensorItem sItem : sensorItems) {
keys = new Keys();
// sItem.getItem().get
keys.setMetric(sItem.getItem().getKey());
keys.setKey(this.mappingMap.get(sItem.getItem().getId()));
keysList.add(keys);
}
item.setKeys(keysList);
QueryInfo queryInfo = new QueryInfo();
queryInfo.setQuery("show status");
item.setQueryInfo(queryInfo);
MappingInfo mappingInfo = new MappingInfo();
mappingInfo.setParseDirection("row");
mappingInfo.setValueColumn("Value");
List<String> keyColumns = new ArrayList<>();
keyColumns.add("Variable_name");
mappingInfo.setKeyColumns(keyColumns);
item.setMappingInfo(mappingInfo);
List<Item> itemList = new ArrayList<>();
itemList.add(item);
config.setItems(itemList);
ObjectMapper objectMapper = new ObjectMapper();
return objectMapper.writeValueAsString(config);
}
private InfraHost getInfraHost(Infra infra) {
switch (infra.getInfraType().getId()) {
case 1:
InfraMachine infraMachine = (InfraMachine)infra;
break;
case 2:
InfraHost infraHost = (InfraHost)infra;
return infraHost;
case 3:
InfraOS infraOS = (InfraOS)infra;
break;
case 4:
InfraOSApplication infraOSApplication = (InfraOSApplication)infra;
break;
case 5:
InfraOSDaemon infraOSDaemon = (InfraOSDaemon)infra;
case 6:
InfraOSPort infraOSPort = (InfraOSPort)infra;
break;
case 7:
com.loafle.overflow.module.infra.model.InfraService infraOSService = (com.loafle.overflow.module.infra.model.InfraService)infra;
return infraOSService.getHost();
}
return null;
}
}

View File

@ -501,6 +501,187 @@ INSERT INTO meta_sensor_item (id,create_date,"key",name,type_id) VALUES (
'94','2017-06-26 20:10','Performance.mysql.schema.users.lost','Performance_mysql_schema_users_lost','6');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Innodb_buffer_pool_dump_status','11','5');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Innodb_buffer_pool_load_status','11','6');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Innodb_buffer_pool_resize_status','11','7');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Innodb_buffer_pool_pages_data','11','8');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Innodb_buffer_pool_bytes_data','11','9');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Innodb_buffer_pool_pages_dirty','11','10');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Innodb_buffer_pool_bytes_dirty','11','11');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Innodb_buffer_pool_pages_flushed','11','12');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Innodb_buffer_pool_pages_free','11','13');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Innodb_buffer_pool_pages_misc','11','14');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Innodb_buffer_pool_pages_total','11','15');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Innodb_buffer_pool_read_ahead_rnd','11','16');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Innodb_buffer_pool_read_ahead','11','17');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Innodb_buffer_pool_read_ahead_evicted','11','18');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Innodb_buffer_pool_read_requests','11','19');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Innodb_buffer_pool_reads','11','20');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Innodb_buffer_pool_wait_free','11','21');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Innodb_buffer_pool_write_requests','11','22');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Innodb_data_fsyncs','11','23');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Innodb_data_pending_fsyncs','11','24');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Innodb_data_pending_reads','11','25');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Innodb_data_pending_writes','11','26');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Innodb_data_read','11','27');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Innodb_data_reads','11','28');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Innodb_data_writes','11','29');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Innodb_data_written','11','30');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Innodb_dblwr_pages_written','11','31');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Innodb_dblwr_writes','11','32');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Innodb_log_waits','11','33');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Innodb_log_write_requests','11','34');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Innodb_log_writes','11','35');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Innodb_os_log_fsyncs','11','36');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Innodb_os_log_pending_fsyncs','11','37');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Innodb_os_log_pending_writes','11','38');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Innodb_os_log_written','11','39');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Innodb_page_size','11','40');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Innodb_pages_created','11','41');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Innodb_pages_read','11','42');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Innodb_pages_written','11','43');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Innodb_row_lock_current_waits','11','44');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Innodb_row_lock_time','11','45');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Innodb_row_lock_time_avg','11','46');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Innodb_row_lock_time_max','11','47');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Innodb_row_lock_waits','11','48');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Innodb_rows_deleted','11','49');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Innodb_rows_inserted','11','50');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Innodb_rows_read','11','51');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Innodb_rows_updated','11','52');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Innodb_num_open_files','11','53');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Innodb_truncated_status_writes','11','54');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Innodb_available_undo_logs','11','55');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Connection_errors_accept','11','56');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Connection_errors_internal','11','57');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Connection_errors_max_connections','11','58');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Connection_errors_peer_address','11','59');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Connection_errors_select','11','60');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Connection_errors_tcpwrap','11','61');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Connections','11','62');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Max_used_connections','11','63');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Max_used_connections_time','11','64');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Performance_schema_accounts_lost','11','65');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Performance_schema_cond_classes_lost','11','66');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Performance_schema_cond_instances_lost','11','67');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Performance_schema_digest_lost','11','68');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Performance_schema_file_classes_lost','11','69');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Performance_schema_file_handles_lost','11','70');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Performance_schema_file_instances_lost','11','71');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Performance_schema_hosts_lost','11','72');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Performance_schema_index_stat_lost','11','73');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Performance_schema_locker_lost','11','74');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Performance_schema_memory_classes_lost','11','75');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Performance_schema_metadata_lock_lost','11','76');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Performance_schema_mutex_classes_lost','11','77');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Performance_schema_mutex_instances_lost','11','78');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Performance_schema_nested_statement_lost','11','79');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Performance_schema_prepared_statements_lost','11','80');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Performance_schema_program_lost','11','81');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Performance_schema_rwlock_classes_lost','11','82');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Performance_schema_rwlock_instances_lost','11','83');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Performance_schema_session_connect_attrs_lost','11','84');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Performance_schema_socket_classes_lost','11','85');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Performance_schema_socket_instances_lost','11','86');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Performance_schema_stage_classes_lost','11','87');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Performance_schema_statement_classes_lost','11','88');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Performance_schema_table_handles_lost','11','89');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Performance_schema_table_instances_lost','11','90');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Performance_schema_table_lock_stat_lost','11','91');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Performance_schema_thread_classes_lost','11','92');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Performance_schema_thread_instances_lost','11','93');
INSERT INTO meta_sensor_item_key (create_date,"key",crawler_id,item_id) VALUES (
'2017-06-26 19:49','Performance_schema_users_lost','11','94');
INSERT INTO public.meta_vendor_crawler (id,create_date,crawler_id,vendor_id) VALUES (
1,'2017-07-27 15:29:48.634',23,26);

View File

@ -3,6 +3,7 @@ package com.loafle.overflow.module.infra.service;
import com.loafle.overflow.module.domain.model.Domain;
import com.loafle.overflow.module.infra.model.Infra;
import com.loafle.overflow.module.probe.service.ProbeService;
import com.loafle.overflow.module.target.model.Target;
import com.loafle.overflow.spring.AppConfigTest;
import org.codehaus.jackson.map.ObjectMapper;
import org.junit.Test;
@ -11,6 +12,8 @@ import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
import java.io.IOException;
/**
* Created by snoop on 17. 7. 27.
*/
@ -71,6 +74,19 @@ public class InfraServiceTest {
// this.infraService.readAllTargetByProbeList()
}
@Test
public void readByTarget() throws IOException {
Target target = new Target();
target.setId(1);
Infra infra = this.infraService.readByTarget(target);
ObjectMapper objectMapper = new ObjectMapper();
String json = objectMapper.writeValueAsString(infra);
System.out.println(json);
}
// @Test
// public void readAllByProbeList() throws IOException {
//

View File

@ -0,0 +1,36 @@
package com.loafle.overflow.module.meta.service;
import com.loafle.overflow.module.meta.model.MetaCrawler;
import com.loafle.overflow.spring.AppConfigTest;
import org.junit.Assert;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
import java.util.Map;
/**
* Created by snoop on 17. 8. 29.
*/
@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(classes = {AppConfigTest.class})
public class MetaSensorItemKeyServiceTest {
@Autowired
private MetaSensorItemKeyService metaSensorItemKeyService;
@Test
public void readAllByCrawler() {
MetaCrawler metaCrawler = new MetaCrawler();
metaCrawler.setId((short)11);
Map<Integer, String> resultMap = this.metaSensorItemKeyService.readAllByCrawler(metaCrawler);
Assert.assertNotEquals(resultMap.size(), 0);
}
}

View File

@ -14,6 +14,7 @@ import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
import java.io.IOException;
import java.util.Date;
/**
@ -58,6 +59,17 @@ public class SensorServiceTest {
System.out.println(json);
}
@Test
public void generateSensorConfig() throws IOException {
Sensor sensor = new Sensor();
sensor.setId(3);
String result = this.sensorService.generateSensorConfig(sensor);
System.out.println(result);
}
// @Test
// public void readAllByTarget() throws Exception {
// Target target = new Target();