将“info:”从结果查询转换为服务器上的可用数据

bwitn5fc 于 2021-07-24 发布在 Java

关注(0)|答案(1)|浏览(274)

我试图使用结果信息作为条件，但看问题
我有这个问题

REFRESH MATERIALIZED VIEW mvw_test_2020;

此查询显示输出：
'信息：物化视图mvw\U test\U 2020已更新。'
但它不是一个查询结果，例如 select * from some_table 我需要得到这个“信息”值，以验证文本是否正确

'INFO:  Materialized view mvw_test_2020 is already up to date.'

or

'INFO:  Materialized view mvw_net_mdr_not_stone_2020 was incrementally updated successfully.'

or

'INFO:  Materialized view mvw_net_mdr_not_stone_2020 could not be further updated due to inflight updates.'

我需要使用这个日志或查询结果使用xcom或我可以处理的东西，对气流。
有人知道怎么处理吗？
谢谢

sql amazon-redshift airflow

来源：https://stackoverflow.com/questions/63061083/convert-info-from-result-query-to-usable-data-on-airflow

1条答案

按热度按时间

velaa5lx1#

我使用以下查询解决了此问题：

with max_date as ( 
      select max(starttime) as max_starttime 
            ,mv_name 
      from SVL_MV_REFRESH_STATUS 
      group by mv_name 
) 
select trim(SVL_MV_REFRESH_STATUS.mv_name) 
      ,starttime 
      ,endtime 
      ,status 
from SVL_MV_REFRESH_STATUS 
inner join max_date on ( 
      starttime = max_date.max_starttime 
      and SVL_MV_REFRESH_STATUS.mv_name = max_date.mv_name 
);

解释一下，我们有第一个cte max_date 获取包含 mv_name + starttime .
下面的查询包含有价值的信息，可以对 max_date cte只需要一条线 mv_name 得到我想要的，每个物化视图的最后更新。

赞(0）回复(0）举报 2021-07-24

我来回答

将“info:”从结果查询转换为服务器上的可用数据

1条答案

相关问题

热门标签

最新问答