Callbacks

Los callbacks permiten recuperar el estado de un modelo cuando cambia a ‘completo’ o ‘error’. Esto se logra enviando una solicitud POST a la URL especificada, con la carga útil estructurada de la siguiente manera:

adsf

{
    "name": "my_model",
    "version": 1,
    "active": true,
    "predictor_id": 123,
    "predictor_created_at": "Fri, 09 Sep 2023 11:50:27 GMT",
    "old_status": "training",
    "new_status": "complete",
    "changed_at": "Fri, 09 Sep 2023 11:59:00 GMT"
}

Desglosemos cada clave:

• name: nombre del modelo

• version: versión del modelo entrenado

• active: indica si el modelo recién entrenado está activo

• predictor_id: identificador único para el modelo entrenado

• predictor_created_at: tiempo en el que se creó el modelo

• old_status: estado que tenía el modelo antes de recibir elnew_status

• new_status: estado actual del modelo

• changed_at: tiempo en que el estado del modelo cambió deold_statusanew_status

Ten en cuenta que esta función solo funciona en MindsDB Cloud y solo para usuarios deMindsDB Starter.

​

API de Callbacks

La API de Callback proporciona información sobre cómo agregar, obtener, editar y eliminar callbacks.

​

Agregar un Callback

Este es el formato de la Solicitud:

POST /cloud/callback/model_status
Content-Type: application/json
{
  // url will be called on model status change
  "url": "https://my.endpoint.com/"
}

Y este es el formato de la Respuesta:

Status: 200 OK  
Content-Type: application/json
{
  // id of created 'callback'
  "id": 123456
}

​

Obtener un Callback

Este es el formato de la Solicitud:

GET /cloud/callback/model_status

Y este es el formato de la Respuesta:

Status: 200 OK  
Content-Type: application/json
[{
  "id": 123456,
  "created_at": "Fri, 09 Sep 2023 11:50:27 GMT",
  "url": "https://my.endpoint.com/"
}]

​

Editar un Callback

Este es el formato de la Solicitud:

PUT /cloud/callback/model_status/<id>
Content-Type: application/json
{
  // new callback url
  "url": "https://my.endpoint.com/"
}

Y este es el formato de la Respuesta:

Status: 200 OK

​

Eliminar un Callback

Este es el formato de la Solicitud:

DELETE /cloud/callback/model_status/<id>

Y este es el formato de la Respuesta:

Status: 200 OK

​

Manejo de Callbacks usando el SDK de Python

A continuación se muestra un ejemplo de uso de callbacks con el modelohome_rentals. Asegúrate de que tu endpointHOSTNAMEsea accesible desde internet.

Ten en cuenta quelocalhostno es accesible desde internet - puedes hacer quelocalhostsea accesible de varias maneras, comotúnel ngrok.

import requests
import mindsdb_sdk
from flask import Flask, request

MODEL_NAME = 'home_rentals'
HOSTNAME = 'my.endpoint.com'
PORT = 5000

app = Flask(__name__)

con = mindsdb_sdk.connect(
    'https://cloud.mindsdb.com',
    login='[e-mail]',
    password='password'
)

# add callback
con.api.session.post(
    'https://cloud.mindsdb.com/cloud/callback/model_status',
    json={
        'url': f'https://{HOSTNAME}:{PORT}/'
    }
)

@app.route('/', methods=['POST'])
def callback():
    data = request.json
    if data['version'] == 1:
        # let retrain the model
        model = con.models.get(MODEL_NAME)
        model.retrain()
    elif data['version'] == 2:
        # let make a prediciton
        model = con.models.get(MODEL_NAME)
        prediction = model.predict({"sqft": 1000})
        print(prediction)
    return '', 200

# connect to database
db = con.databases.create(
    'example_db',
    engine='postgres',
    connection_args={
        "user": "demo_user",
        "password": "demo_password",
        "host": "3.220.66.106",
        "port": "5432",
        "database": "demo"
    }
)

# train base model
model = con.models.create(
    MODEL_NAME,
    predict='rental_price',
    query=db.tables.get('demo_data.home_rentals')
)

if __name__ == '__main__':
    app.run(host='0.0.0.0', port=PORT)

​

Manejo de Callbacks usando el SDK de JavaScript

A continuación se muestra un ejemplo de uso de callbacks con el modelohome_rentals. Asegúrate de que el callbackHOSTNAMEsea accesible desde MindsDB Cloud.

import express from 'express';
import axios from 'axios';
import * as MindsDB from 'mindsdb-js-sdk';
const mdb = MindsDB.default.default;

const app = express();
const PORT = 54321;
const MODEL_NAME = 'home_rentals';
const HOSTNAME = 'my.endpoint.com';

// Create an Axios instance with interceptors for timeout and error handling
const customAxios = axios.create();
customAxios.interceptors.request.use(config => {
  config.timeout = 120000; // Set a request timeout of 120 seconds
  return config;
});
customAxios.interceptors.response.use(
  response => response,
  error => {
    console.error('Axios Error:', error.message);
    return Promise.reject(error);
  }
);

// Connect to MindsDB Cloud
try {
  await mdb.connect({
    host: 'https://cloud.mindsdb.com',
    user: '[e-mail]',
    password: 'password',
    httpClient: customAxios,
  });
} catch (error) {
  console.error('MindsDB Cloud Connection Error:', error);
  process.exit(1);
}

// Connect to the database
await mdb.Databases.createDatabase('example_db', 'postgres', {
  user: 'demo_user',
  password: 'demo_password',
  host: '3.220.66.106',
  port: '5432',
  database: 'demo',
});

// Express Middleware to parse JSON requests
app.use(express.json());

// Define an Express route to handle model status updates
app.post('/model-status', async (req, res) => {
  const data = req.body;

  if (data.new_status !== 'complete') {
    console.error(`Error! Got model status: ${data.new_status}`);
    return res.status(400).send({ error: 'Invalid model status' });
  }

  const trained_model_version = data.version;
  console.log(`Model training completed, model version=${trained_model_version}`);

  if (trained_model_version === 1) {
    // Base model finished training, let's retrain it
    let model = await mdb.Models.getModel(MODEL_NAME, 'mindsdb');
    model.retrain();
  } else if (trained_model_version === 2) {
    // Model retraining finished, let's make a prediction
    let model = await mdb.Models.getModel(MODEL_NAME, 'mindsdb');
    let prediction = await model.query({
      where: [
        'sqft = 823',
        'location = "good"',
        'neighborhood = "downtown"',
        'days_on_market = 10',
      ],
    });
    console.log(`Prediction: ${JSON.stringify(prediction)}`);
  }

  res.sendStatus(200);
});

// Start the Express server
app.listen(PORT, () => {
  console.log(`Express server started on port ${PORT}`);
});

// Add a callback to notify MindsDB Cloud about the endpoint
try {
  await customAxios.post('https://cloud.mindsdb.com/cloud/callback/model_status', {
    url: `https://${HOSTNAME}:${PORT}/model-status`,
  });
} catch (error) {
  console.error('Callback Error:', error);
}

// Train a model
try {
  await mdb.Models.trainModel(MODEL_NAME, 'rental_price', 'mindsdb', {
    integration: 'example_db',
    select: 'SELECT * FROM demo_data.home_rentals',
  });
} catch (error) {
  console.error('Model Training Error:', error);
}