小编Gal*_*hak的帖子

我正在尝试创建以下视图：

CREATE OR REPLACE VIEW view_events AS 
(
   SELECT
     "rank"() OVER (PARTITION BY "tb1"."innerid" ORDER BY "tb1"."date" ASC) "r"
   , "tb2"."opcode"
   , "tb1"."innerid"
   , "tb1"."date"
   , From_iso8601_timestamp(tb1.date) as "real_date"
   , "tb2"."eventtype"
   , "tb1"."fuelused"
   , "tb1"."mileage"
   , "tb1"."latitude"
   , "tb1"."longitude"
   FROM
     rt_message_header tb1
   , rt_messages tb2
   WHERE ((("tb1"."uuid" = "tb2"."header_uuid") AND ("tb2"."opcode" = '39')) AND ("tb2"."type" = 'event'))
   ORDER BY "tb1"."innerid" ASC, "tb1"."date" ASC
)

它给了我以下错误：

您的查询具有以下错误：不支持的配置单元类型：带有时区的时间戳

但是，当我自己运行查询时，它可以正常工作，并且在这里提到From_iso8601_timestamp 作为有效的日期函数。

谁能告诉我我在做什么错？

我需要执行从 nifi 到 couchbase 的获取请求。curl 命令是：

curl http://HOST:PORT/query/service -d "statement=select item.Date from bucket unnest bucket as item" -u USER:PASSWORD

我尝试使用 InvokeHttp 和 ExecuteStreamCommand 但它一直返回错误（状态代码 400）。完整的错误信息是：

{ "requestID": "bff62c0b-36fd-401d-bca0-0959e0944323", "errors": [{"code":1050,"msg":"No statement or Prepared value"}], "status": "fatal" , "metrics": {"elapsedTime": "113.31µs","executionTime": "74.321µs","re​​sultCount": 0,"resultSize": 0,"errorCount": 1

重要的是，我更喜欢 http 请求将由传入的流文件触发。我尝试以各种方式使用处理器，但没有一个有效。当我从 nifi 服务器运行命令时，它工作正常。

谢谢您的帮助