Tus usuarios preguntan. Tu sistema responde con SQL seguro.

curl -X POST https://app.datafala.com.br/v1/ask \
  -H "Authorization: Bearer $DATAFALA_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{"question": "cuánto vendí del producto X en los últimos 6 meses", "end_user": "usr_8f3a91c2d4e7b605", "max_rows": 100}'

import httpx, psycopg

resposta = httpx.post(
    "https://app.datafala.com.br/v1/ask",
    headers={"Authorization": f"Bearer {API_KEY}"},
    json={
        "question": "clientes que más compraron este mes",
        "end_user": ID_DO_USUARIO,  # id opaco de tu usuario (16 a 128 caracteres)
    },
).json()

with psycopg.connect(
    DATABASE_URL_SOMENTE_LEITURA,
    options="-c statement_timeout=5000 -c default_transaction_read_only=on",
) as conn:
    linhas = conn.execute(resposta["sql"], resposta["params"]).fetchall()

import httpx
from django.db import connections

def perguntar(pergunta, id_do_usuario):
    resposta = httpx.post(
        "https://app.datafala.com.br/v1/ask",
        headers={"Authorization": f"Bearer {API_KEY}"},
        json={"question": pergunta, "end_user": id_do_usuario},
    ).json()

    # "leitura" es una base de datos configurada con un usuario de solo lectura
    with connections["leitura"].cursor() as cursor:
        cursor.execute(resposta["sql"], resposta["params"])
        return cursor.fetchall()

import httpx, psycopg
from fastapi import FastAPI

app = FastAPI()

@app.get("/perguntar")
async def perguntar(pergunta: str, id_do_usuario: str):
    async with httpx.AsyncClient() as client:
        r = await client.post(
            "https://app.datafala.com.br/v1/ask",
            headers={"Authorization": f"Bearer {API_KEY}"},
            json={"question": pergunta, "end_user": id_do_usuario},
        )
    resposta = r.json()

    # conexión con un usuario de solo lectura
    async with await psycopg.AsyncConnection.connect(DATABASE_URL_SOMENTE_LEITURA) as conn:
        cur = await conn.execute(resposta["sql"], resposta["params"])
        return await cur.fetchall()

import { Client } from "pg";

interface Resposta {
  sql: string;
  params: Record<string, unknown>;
}

const r = await fetch("https://app.datafala.com.br/v1/ask", {
  method: "POST",
  headers: {
    Authorization: "Bearer " + process.env.DATAFALA_API_KEY,
    "Content-Type": "application/json",
  },
  body: JSON.stringify({
    question: "clientes que más compraron este mes",
    end_user: idDoUsuario, // id opaco de tu usuario (16 a 128 caracteres)
  }),
});
const resposta = (await r.json()) as Resposta;

// pg usa $1, $2…: reemplaza cada %(name)s por el valor posicional y %% por %
const valores: unknown[] = [];
const sql = resposta.sql.replace(/%%|%\((\w+)\)s/g, (trecho, nome: string) => {
  if (trecho === "%%") return "%"; // el %% de los literales vuelve a ser %
  valores.push(resposta.params[nome]);
  return "$" + valores.length;
});

const db = new Client({ connectionString: process.env.DATABASE_URL_SOMENTE_LEITURA });
await db.connect();
const { rows } = await db.query(sql, valores);

const { Client } = require("pg");

async function perguntar(pergunta, idDoUsuario) {
  const r = await fetch("https://app.datafala.com.br/v1/ask", {
    method: "POST",
    headers: {
      Authorization: "Bearer " + process.env.DATAFALA_API_KEY,
      "Content-Type": "application/json",
    },
    body: JSON.stringify({ question: pergunta, end_user: idDoUsuario }),
  });
  const resposta = await r.json();

  // pg usa $1, $2…: reemplaza cada %(name)s por el valor posicional y %% por %
  const valores = [];
  const sql = resposta.sql.replace(/%%|%\((\w+)\)s/g, (trecho, nome) => {
    if (trecho === "%%") return "%"; // el %% de los literales vuelve a ser %
    valores.push(resposta.params[nome]);
    return "$" + valores.length;
  });

  // conexión con un usuario de solo lectura
  const db = new Client({ connectionString: process.env.DATABASE_URL_SOMENTE_LEITURA });
  await db.connect();
  const { rows } = await db.query(sql, valores);
  await db.end();
  return rows;
}

using System.Net.Http.Json;
using System.Text.Json;
using System.Text.RegularExpressions;
using Npgsql;

var http = new HttpClient();
http.DefaultRequestHeaders.Add("Authorization", "Bearer " + apiKey);

var r = await http.PostAsJsonAsync(
    "https://app.datafala.com.br/v1/ask",
    new
    {
        question = "clientes que más compraron este mes",
        end_user = idDoUsuario, // id opaco de tu usuario (16 a 128 caracteres)
    });
var resposta = await r.Content.ReadFromJsonAsync<JsonElement>();

// Npgsql usa @nombre: reemplaza cada %(name)s y deshace el %% de los literales
var sql = Regex.Replace(resposta.GetProperty("sql").GetString()!, @"%%|%\((\w+)\)s",
    m => m.Value == "%%" ? "%" : "@" + m.Groups[1].Value);

// conexión con un usuario de solo lectura
await using var conn = new NpgsqlConnection(connStringSomenteLeitura);
await conn.OpenAsync();
await using var cmd = new NpgsqlCommand(sql, conn);
foreach (var p in resposta.GetProperty("params").EnumerateObject())
{
    object valor = p.Value.ValueKind switch
    {
        JsonValueKind.Number => p.Value.GetDecimal(),
        JsonValueKind.String => p.Value.GetString()!,
        JsonValueKind.Null => DBNull.Value,
        _ => p.Value.ToString(),
    };
    cmd.Parameters.AddWithValue(p.Name, valor);
}
await using var leitor = await cmd.ExecuteReaderAsync();

uses
  System.SysUtils, System.Classes, System.JSON, System.Net.HttpClient,
  System.RegularExpressions, FireDAC.Comp.Client;

function Perguntar(const Pergunta, IdDoUsuario: string): TFDQuery;
var
  Http: THTTPClient;
  Json: TJSONObject;
  Corpo: TStringStream;
  Retorno: IHTTPResponse;
  Resposta: TJSONObject;
  Par: TJSONPair;
  Sql: string;
begin
  Json := TJSONObject.Create;
  Http := THTTPClient.Create;
  try
    Json.AddPair('question', Pergunta);
    // id opaco de tu usuario (16 a 128 caracteres)
    Json.AddPair('end_user', IdDoUsuario);
    Corpo := TStringStream.Create(Json.ToJSON, TEncoding.UTF8);
    try
      Http.ResponseTimeout := 60000;
      Http.ContentType := 'application/json';
      Http.CustomHeaders['Authorization'] := 'Bearer ' + ApiKey;
      Retorno := Http.Post('https://app.datafala.com.br/v1/ask', Corpo);
    finally
      Corpo.Free;
    end;
  finally
    Http.Free;
    Json.Free;
  end;
  Resposta := TJSONObject.ParseJSONValue(Retorno.ContentAsString(TEncoding.UTF8)) as TJSONObject;
  try
    if Retorno.StatusCode <> 200 then
      raise Exception.Create(Resposta.GetValue<string>('code'));

    // FireDAC usa :nombre: reemplaza cada %(name)s y deshace el %% de los literales
    Sql := StringReplace(Resposta.GetValue<string>('sql'), '%%', #1, [rfReplaceAll]);
    Sql := TRegEx.Replace(Sql, '%\((\w+)\)s', ':$1');
    Sql := StringReplace(Sql, #1, '%', [rfReplaceAll]);

    // FDConexaoLeitura usa un usuario de solo lectura
    Result := TFDQuery.Create(nil);
    Result.Connection := FDConexaoLeitura;
    Result.ResourceOptions.MacroCreate := False;
    Result.ResourceOptions.MacroExpand := False;
    Result.ResourceOptions.EscapeExpand := False;
    Result.SQL.Text := Sql;
    for Par in Resposta.GetValue<TJSONObject>('params') do
      if Par.JsonValue is TJSONNumber then
        Result.ParamByName(Par.JsonString.Value).AsFloat := TJSONNumber(Par.JsonValue).AsDouble
      else
        Result.ParamByName(Par.JsonString.Value).AsString := Par.JsonValue.Value;
    Result.Open;
  finally
    Resposta.Free;
  end;
end;