scala – AWS Lambda – 如何获取来自AWS IOT的数据主题名称

我正在使用AWS IOT源测试AWS Lambda.我的mqtt客户端正在发布不同的主题：设备A将数据发布到流/ A,设备B将数据发布到流/ B中,因此在AWS Lambda中我定义了一个SQL规则,选择来自主题流/的主题的所有设备.问题是,现在我没有设备源的信息,因为我只有一个带有额外信息的数组[Byte]].如果有人有解决方案来访问带有主题信息的mqtt有效负载,我会接受它！

import java.io.{ByteArrayOutputStream,InputStream,OutputStream}
import com.amazonaws.services.lambda.runtime.{Context,RequestStreamHandler}
/**
  * Created by alifirat on 24/04/17.
  */
class IOTConsumer extends RequestStreamHandler {

  val BUFFER_SIZE = 1024 * 4

  override def handleRequest(input: InputStream,output: OutputStream,context: Context): Unit = {
    val bytes = toByteArray(input)
    val logger= context.getLogger
    logger.log("Receive following thing :"  + new String(bytes))
    output.write(bytes)
  }

   /**
     * Reads and returns the rest of the given input stream as a byte array.
     * Caller is responsible for closing the given input stream.
     */
   def toByteArray(is : InputStream) : Array[Byte] = {
     val output = new ByteArrayOutputStream()
     try {
       val b = new Array[Byte](BUFFER_SIZE);
       var n = 0
       var flag = true
       while(flag) {
         n = is.read(b)
         if(n == -1) flag = false
         else {
           output.write(b,n)
         }
       }
       output.toByteArray();
     } finally {
       output.close();
       Array[Byte]()
     }
   }
}

*,topic() as topic

SELECT *,topic() as topic FROM one/of/my/+/topics