Como usar a função PARSE_JSON - Realtime Compute for Apache Flink: Central de Documentação do Alibaba Cloud

Nota

Esta função tem suporte apenas no Ververica Runtime (VVR) 11.1.0 ou posterior.

Sintaxe

VARIANT PARSE_JSON(VARCHAR jsonStr [, BOOLEAN allowDuplicateKeys])

Argumento	Tipo de dados	Descrição
`jsonStr`	VARCHAR	String JSON a analisar.
`allowDuplicateKeys`	BOOLEAN	(Opcional) Defina se chaves duplicadas são permitidas. `true`: retém o valor da última chave duplicada. `false` (padrão): gera erro se houver chaves duplicadas.

Função	Tratamento de erros	Valor de retorno para JSON inválido	Quando usar
PARSE_JSON	Gera erro	Erro	Validação rigorosa de entrada necessária
TRY_PARSE_JSON	Tolerante a erros	NULL	Entrada inválida aceitável

Tabela de entrada T1:

jsonString (VARCHAR)

{"k": "v1", "k2": 1}

SELECT PARSE_JSON(jsonString) AS v
FROM T1;

Resultado:

v (VARIANT)

{"k": "v1", "k2": 1}

Por padrão, PARSE_JSON gera erro ao detectar chaves duplicadas:

SELECT PARSE_JSON('{"a": "123", "b": "456", "a": "789"}') AS v;

Para reter o último valor de cada chave duplicada, defina allowDuplicateKeys como true:

SELECT PARSE_JSON('{"a": "123", "b": "456", "a": "789"}', true) AS v;