- createSchemaBq(result, queryString, schemaName) ⇒
Array Monta as linhas para serem inseridas no BQ
- addTimestamp(data) ⇒
Object Adiciona o atributo data para o objeto, contendo o timestamp do momento da execução
- insertRowsAsStream(data)
Realiza a persistências dos dados por Stream no BigQuery
- loadProjectConfig()
Carrega o arquivo de configuração armazenado no GCS
- trace(log)
Enviado o log para o stdout, se somente se, a variável debugging = true
Monta as linhas para serem inseridas no BQ
Kind: global function
Returns: Array - Dados estruturados para o BQ
| Param | Type | Description |
|---|---|---|
| result | Array |
Status das chaves validadas |
| queryString | Object |
|
| schemaName | String |
Identificação do schema usado para validação |
Adiciona o atributo data para o objeto, contendo o timestamp do momento da execução
Kind: global function
Returns: Object - Objeto com o atributo no padrão yyyy-mm-ddThh:mm:ss
| Param | Type | Description |
|---|---|---|
| data | Object |
Objeto |
Realiza a persistências dos dados por Stream no BigQuery
Kind: global function
| Param | Type | Description |
|---|---|---|
| data | Array |
Dados estruturados no padrão de persistência do BQ |
Carrega o arquivo de configuração armazenado no GCS
Enviado o log para o stdout, se somente se, a variável debugging = true
Kind: global function
| Param | Type | Description |
|---|---|---|
| log | Object |
Que será apresentado no stdout |