如何从 http 请求(接收器)响应中获取源消息?
How get source message from http-request (sink) response?
我向 http 服务发出 http 请求 ({f_id:1001}
)。服务 return 只有我 true/false 结果没有来源 f_id。
并希望 select 对它的响应与来源 F_ID:
@sink(type='http-request', publisher.url='http://127.0.0.1:3020/',
method="POST", sink.id='download-sink', @map(type='json'))
define stream OutputToNodejs(f_id long);
@source(type='http-response' , sink.id='download-sink',
http.status.code='200',
@map(type='json', @attributes('result')))
define stream responseStream2xx(result bool);
@info(name = 'SimpleLogTrigger')
from responseStream2xx
select result as text, f_id_from_request /* HOW GET F_ID from source request HERE */
insert into OutputStream2;
而且我想使用来自源响应的 select 中的源请求消息。但是我怎么能在这里得到源消息呢?
如果我做不到 - 也许我可以将它的一些 ID 从请求转发到响应?
目前没有现成的方法可以做到这一点。有两种解决方法可以完成此操作。
- 在响应中也制作您的服务 return f_id 并将其放入其中
响应流
- 改进 HTTP request sink 和 HTTP
响应 source 以便 source 可以访问 sink 的流
变量。但这将是一项重大的开发工作。所以我认为
第一个是更好的选择,因为您可以管理
HTTP 服务。
我向 http 服务发出 http 请求 ({f_id:1001}
)。服务 return 只有我 true/false 结果没有来源 f_id。
并希望 select 对它的响应与来源 F_ID:
@sink(type='http-request', publisher.url='http://127.0.0.1:3020/',
method="POST", sink.id='download-sink', @map(type='json'))
define stream OutputToNodejs(f_id long);
@source(type='http-response' , sink.id='download-sink',
http.status.code='200',
@map(type='json', @attributes('result')))
define stream responseStream2xx(result bool);
@info(name = 'SimpleLogTrigger')
from responseStream2xx
select result as text, f_id_from_request /* HOW GET F_ID from source request HERE */
insert into OutputStream2;
而且我想使用来自源响应的 select 中的源请求消息。但是我怎么能在这里得到源消息呢? 如果我做不到 - 也许我可以将它的一些 ID 从请求转发到响应?
目前没有现成的方法可以做到这一点。有两种解决方法可以完成此操作。
- 在响应中也制作您的服务 return f_id 并将其放入其中 响应流
- 改进 HTTP request sink 和 HTTP 响应 source 以便 source 可以访问 sink 的流 变量。但这将是一项重大的开发工作。所以我认为 第一个是更好的选择,因为您可以管理 HTTP 服务。