Consulte um banco de dados de uma function

Leia linhas do SQL Database dentro de uma function com o módulo de runtime azion:sql, e retorne essas linhas na resposta que a function envia.

Última atualização

Ver como Markdown Configurar agente

Você lê linhas de um banco de dados no SQL Database dentro de uma function, durante a requisição que a function atende. O módulo de runtime azion:sql abre a conexão e executa o SQL.

Esta página traz uma function completa. Para todos os métodos que o módulo expõe, consulte SQL Database API.

Pré-requisitos

  • Uma aplicação para instanciar a function. Consulte Instancie uma função em uma aplicação.
  • Um personal token para autorizar as requisições à API.
  • A permissão Edit SQL Database, que concede permissão para criar e editar bancos de dados e os seus dados pela API da Azion. Consulte Teams Permissions.
  • SQL Database habilitado na sua conta. O produto está em Preview e não é habilitado por padrão, então solicite acesso pelo Technical Support.

Crie o banco de dados e a tabela

A function lê uma tabela que já existe, então as duas chamadas abaixo são o caminho mais curto até uma. Para criar o banco de dados e preenchê-lo com linhas:

Crie o banco de dados
Shell
01curl --location --request POST 'https://api.azion.com/v4/workspace/sql/databases' \
02--header 'Accept: application/json' \
03--header 'Content-Type: application/json' \
04--header 'Authorization: Token [TOKEN VALUE]' \
05--data '{"name":"mydatabase"}'

A API responde com HTTP 202 e retorna o identificador que a próxima chamada usa no seu caminho:

JSON
01{
02 "state": "pending",
03 "data": {
04 "id": 1234,
05 "name": "mydatabase",
06 "status": "creating",
07 "active": true,
08 "last_modified": "2026-01-01T12:00:00.000000Z",
09 "last_editor": "user@example.com",
10 "product_version": "1.0"
11 }
12}

O provisionamento leva cerca de 15 segundos. Envie GET /databases/{database_id} até que status marque created.

Crie a tabela e insira as linhas
Shell
01curl --location --request POST 'https://api.azion.com/v4/workspace/sql/databases/<database-id>/query' \
02--header 'Accept: application/json' \
03--header 'Content-Type: application/json' \
04--header 'Authorization: Token [TOKEN VALUE]' \
05--data '{"statements":["CREATE TABLE users (id INTEGER PRIMARY KEY, name TEXT NOT NULL);","INSERT INTO users VALUES (1, '\''user 1'\'');","INSERT INTO users VALUES (2, '\''user 2'\'');","INSERT INTO users VALUES (3, '\''user 3'\'');"]}'

A API responde com HTTP 200 e "state": "executed", e data traz uma entrada por statement, na ordem em que você as enviou.

O banco de dados mydatabase contém uma tabela users com três linhas. O nome que você define aqui é o nome que a function passa para Database.open.

nota — Um statement que falha não faz a requisição falhar. A chamada ainda responde HTTP 200, e a entrada desse statement traz error em vez de results, então leia data[].error antes de considerar a chamada concluída.

Escreva a function

Database.open abre uma conexão com a réplica de leitura do banco de dados, então uma function lê os dados e não escreve neles. O handler abaixo responde a uma requisição GET com o conteúdo de users:

JavaScript
01import { Database } from "azion:sql";
02
03async function db_query() {
04 let connection = await Database.open("mydatabase");
05 let rows = await connection.query("select * from users");
06 let column_count = rows.columnCount();
07 let column_names = [];
08 for (let i = 0; i < column_count; i++) {
09 column_names.push(rows.columnName(i));
10 }
11 let response_lines = [];
12 response_lines.push(column_names.join("|"));
13 let row = await rows.next();
14 while (row) {
15 let row_items = [];
16 for (let i = 0; i < column_count; i++) {
17 row_items.push(row.getString(i));
18 }
19 response_lines.push(row_items.join("|"));
20 row = await rows.next();
21 }
22 const response_text = response_lines.join("\n");
23 return response_text;
24}
25
26async function handle_request(request) {
27 if (request.method != "GET") {
28 return new Response("Method not allowed", { status: 405 });
29 }
30 try {
31 return new Response(await db_query());
32 } catch (e) {
33 console.log(e.message, e.stack);
34 return new Response(e.message, { status: 500 });
35 }
36}
37
38addEventListener("fetch", (event) =>
39 event.respondWith(handle_request(event.request))
40);

connection.query retorna um handle de linhas. rows.columnCount() e rows.columnName(i) nomeiam as colunas, rows.next() avança uma linha e retorna um valor falsy quando o conjunto de resultados termina, e row.getString(i) lê uma célula pela sua posição. O exemplo junta as células de uma linha com | e as linhas com uma quebra de linha, e depois envia o texto como corpo da resposta. Uma falha dentro do módulo é registrada com e.message e e.stack e retornada como HTTP 500.

nota — O exemplo lê dados, então ele responde a GET e recusa todos os outros métodos com 405. Ajuste a verificação para os métodos que a sua própria lógica atende.

Instancie e execute a function

Uma function só é executada depois de ser vinculada a uma aplicação e de uma regra dessa aplicação selecioná-la. Para executar a function e ler as linhas:

Crie a function no Azion Console

Acesse Azion Console e crie uma function que carrega o código acima. Consulte Functions.

Instancie a function em uma aplicação

Vincule a function à aplicação que atende o seu domínio e adicione a regra que executa a instância. Consulte Instancie uma função em uma aplicação.

Faça uma requisição à aplicação
curl 'https://<your-application-domain>/'

A resposta traz os nomes das colunas na primeira linha e uma linha para cada registro de users:

Texto
01id|name
021|user 1
032|user 2
043|user 3

Próximos passos

SQL Database APITodos os métodos que o módulo azion:sql expõe a uma function, com a sua assinatura.Crie tabelas e consulte dadosDefina as tabelas que a function lê, insira linhas e leia-as de volta com SQL.Instancie uma função em uma aplicaçãoVincule a function a uma aplicação, nomeie a instância e passe os seus Args em JSON.Bancos de dados e consultasTodos os campos, operações, envelopes e códigos de erro dos endpoints do SQL Database.