PostgreSQL
 sql >> Base de Dados >  >> RDS >> PostgreSQL

Como calcular uma média móvel exponencial no postgres?


Você pode definir sua própria função agregada e usá-la com uma especificação de janela para obter a saída agregada em cada estágio, em vez de um único valor.

Portanto, uma agregação é uma parte do estado e uma função de transformação para modificar esse estado para cada linha e, opcionalmente, uma função de finalização para converter o estado em um valor de saída. Para um caso simples como este, apenas uma função de transformação deve ser suficiente.
create function ema_func(numeric, numeric) returns numeric
  language plpgsql as $$
declare
  alpha numeric := 0.5;
begin
  -- uncomment the following line to see what the parameters mean
  -- raise info 'ema_func: % %', $1, $2;
  return case
              when $1 is null then $2
              else alpha * $2 + (1 - alpha) * $1
         end;
end
$$;
create aggregate ema(basetype = numeric, sfunc = ema_func, stype = numeric);

que me dá:
[email protected]@[local] =# select x, ema(x, 0.1) over(w), ema(x, 0.2) over(w) from data window w as (order by n asc) limit 5;
     x     |      ema      |      ema      
-----------+---------------+---------------
 44.988564 |     44.988564 |     44.988564
   39.5634 |    44.4460476 |    43.9035312
 38.605724 |   43.86201524 |   42.84396976
 38.209646 |  43.296778316 |  41.917105008
 44.541264 | 43.4212268844 | 42.4419368064

Esses números parecem corresponder à planilha que você adicionou à pergunta.

Além disso, você pode definir a função para passar alfa como um parâmetro da instrução:
create or replace function ema_func(state numeric, inval numeric, alpha numeric)
  returns numeric
  language plpgsql as $$
begin
  return case
         when state is null then inval
         else alpha * inval + (1-alpha) * state
         end;
end
$$;

create aggregate ema(numeric, numeric) (sfunc = ema_func, stype = numeric);

select x, ema(x, 0.5 /* alpha */) over (order by n asc) from data

Além disso, esta função é realmente tão simples que não precisa estar em plpgsql, mas pode ser apenas uma função sql, embora você não possa se referir a parâmetros por nome em uma delas:
create or replace function ema_func(state numeric, inval numeric, alpha numeric)
  returns numeric
  language sql as $$
select case
       when $1 is null then $2
       else $3 * $2 + (1-$3) * $1
       end
$$;