建立在Tablestore的Wifi设备监管系统架构实现

<dependency>

  <groupid>com.aliyun.openservices</groupid>

  <artifactid>tablestore</artifactid>

  <version>4.11.0</version>

</dependency>

private void init() {

  asyncclient asyncclient = new asyncclient(endpoint, accesskeyid, accesskeysecret, instance);

  timestreamdbconfiguration conf = new timestreamdbconfiguration( "metatablename" );

  timestreamdbclient db = new timestreamdbclient(asyncclient, conf);

}

public void createtable() {

  db.createmetatable(arrays.aslist(

  new attributeindexschema( "group" , attributeindexschema.type.keyword),

  new attributeindexschema( "id" , attributeindexschema.type.keyword),

  new attributeindexschema( "status" , attributeindexschema.type.keyword),

  new attributeindexschema( "version" , attributeindexschema.type.keyword),

  new attributeindexschema( "location" , attributeindexschema.type.geo_point)

  ));

  db.createdatatable( "datatablename" );

}

//metawriter对应meta表，提供读、写接口

timestreammetatable metawriter = db.metatable();

//identifier作为时间线的身份标识（ unique ），含： name 、tags，

timestreamidentifier identifier = new timestreamidentifier.builder( "wifi" )

  .addtag( "mac" , "mock:mac:1:1" )

  .build();

//基于identifier创建meta对象，并为meta设置更多属性，attributes为属性参数

timestreammeta meta = new timestreammeta(identifier)

  .addattribute( "group" , "group-1" )

  .addattribute( "id" , "id-1" )

  .addattribute( "version" , "v1.0" )

  .addattribute( "status" , "normal" )

  .addattribute( "location" , "30,120" );

//创建新的时间线，然后写入监控数据

metawriter.put(meta);

//datawriter分别对应data表，提供读、写接口

timestreamdatatable datawriter = db.datatable( "datatablename" );

timestreammeta meta；//meta上一步已经构建

//创建新的时间线，然后写入监控数据

datawriter.asyncwrite(

  meta.getidentifier(),//identifier identifier

  new point.builder(i, timeunit.seconds)

  .addfield( "cpu" , 30)

  .addfield( "ram" , 29)

  .addfield( "flash_used" , 20)

  .addfield( "flash_total" , 1048576)

  .build()

);

//reader对应meta表，提供读、写接口，此处名字为突出读功能

timestreammetatable metareader = db.metatable();

//构建筛选条件

filter filter = new andfilter(arrays.aslist(

  name .equal( "wifi" ),

  tag.equal( "mac" , "mock:mac:1:1" ),

  attribute.ingeodistance( "location" , "30,120" , 100000)

));

iterator<timestreammeta> iterator = metareader

  .filter(filter)

  .fetchall();

while (iterator.hasnext()) {

  timestreammeta meta = iterator. next ();//deal with metas

}

//datawriter分别对应data表，提供读、写接口

timestreamdatatable datareader = db.datatable( "datatablename" );

timestreammeta meta；//基于已获取的meta列表，分别获取每个时间线的有序监控数据

iterator<point> iterator = reader.get(meta.getidentifier())

  . select ( "flash_used" , "flash_total" )//设置返回的列

  .timerange(timerange.range(0, long.max_value, timeunit.seconds))

  .fetchall();

while (iterator.hasnext()) {

  point point = iterator. next ();//deal with points

  long timestamp = point.gettimestamp(timeunit.milliseconds);//毫秒单位时间戳

  long flashused = point.getfield( "flash_used" ).aslong();//获取该点long类型的数据大小监控

  long flashuotal = point.getfield( "flash_total" ).aslong();//获取该点long类型的数据大小监控

}