o U|%i@svdZddlmZmZddlZddlZddlm Z ddl m Z ddl m Z ddlmZddlmZGd d d e e ZdS) zwClassifier utilities for MySQL Connector/Python. Provides a scikit-learn compatible classifier backed by HeatWave ML. )OptionalUnionN)ClassifierMixin) MyBaseMLModel)ML_TASK) copy_dict)MySQLConnectionAbstractc @seZdZdZ    ddedeedeedeedeef dd Zd e e j e j fd e j fd d Zd e e j e j fd e j fddZd e e j e j fd e j fddZdS) MyClassifiera MySQL HeatWave scikit-learn compatible classifier estimator. Provides prediction and probability output from a model deployed in MySQL, and manages fit, explain, and prediction options as per HeatWave ML interface. Attributes: predict_extra_options (dict): Dictionary of optional parameters passed through to the MySQL backend for prediction and probability inference. _model (MyModel): Underlying interface for database model operations. fit_extra_options (dict): See MyBaseMLModel. Args: db_connection (MySQLConnectionAbstract): Active MySQL connector DB connection. model_name (str, optional): Custom name for the model. fit_extra_options (dict, optional): Extra options for fitting. explain_extra_options (dict, optional): Extra options for explanations. predict_extra_options (dict, optional): Extra options for predict/predict_proba. Methods: predict(X): Predict class labels. predict_proba(X): Predict class probabilities. N db_connection model_namefit_extra_optionsexplain_extra_optionspredict_extra_optionscCs.tj||tj||dt||_t||_dS)a Initialize a MyClassifier. Args: db_connection: Active MySQL connector database connection. model_name: Optional, custom model name. fit_extra_options: Optional fit options. explain_extra_options: Optional explain options. predict_extra_options: Optional predict/predict_proba options. Raises: DatabaseError: If a database connection issue occurs. If an operational error occurs during execution. )r r N)r__init__rCLASSIFICATIONrrr )selfr r r r rrS/home/air/sos_test/back/venv/lib/python3.10/site-packages/mysql/ai/ml/classifier.pyrGs zMyClassifier.__init__XreturncCs|jj||jd}|dS)a Predict class labels for the input features using the MySQL model. References: https://dev.mysql.com/doc/heatwave/en/mys-hwaml-ml-predict-table.html A full list of supported options can be found under "ML_PREDICT_TABLE Options" Args: X: Input samples as a numpy array or pandas DataFrame. Returns: ndarray: Array of predicted class labels, shape (n_samples,). Raises: DatabaseError: If provided options are invalid or unsupported, or if the model is not initialized, i.e., fit or import has not been called If a database connection issue occurs. If an operational error occurs during execution. options Prediction)_modelpredictrto_numpyrrresultrrrrhs zMyClassifier.predictcsH|jj||jd}t|djddt|dfddS)a* Predict class probabilities for the input features using the MySQL model. References: https://dev.mysql.com/doc/heatwave/en/mys-hwaml-ml-predict-table.html A full list of supported options can be found under "ML_PREDICT_TABLE Options" Args: X: Input samples as a numpy array or pandas DataFrame. Returns: ndarray: Array of shape (n_samples, n_classes) with class probabilities. Raises: DatabaseError: If provided options are invalid or unsupported, or if the model is not initialized, i.e., fit or import has not been called If a database connection issue occurs. If an operational error occurs during execution. r ml_resultsr probabilitiescsfddDS)Ncsg|]}d|qS)rr).0 class_name ml_resultrr s z@MyClassifier.predict_proba....rr"classesr"rs z,MyClassifier.predict_proba..) rrrsortedilockeysnpstackmaprrr%r predict_probas zMyClassifier.predict_probacCs|jj||jddS)ai Explain model predictions using provided data. References: https://dev.mysql.com/doc/heatwave/en/mys-hwaml-ml-explain-table.html A full list of supported options can be found under "ML_EXPLAIN_TABLE Options" Args: X: DataFrame for which predictions should be explained. Returns: DataFrame containing explanation details (feature attributions, etc.) Raises: DatabaseError: If provided options are invalid or unsupported, or if the model is not initialized, i.e., fit or import has not been called If a database connection issue occurs. If an operational error occurs during execution. Notes: Temporary input/output tables are cleaned up after explanation. rN)rexplain_predictionsr )rrrrrr/sz MyClassifier.explain_predictions)NNNN)__name__ __module__ __qualname____doc__rrstrdictrrpd DataFramer+ndarrayrr.r/rrrrr .s@ !  $r )r3typingrrnumpyr+pandasr6 sklearn.basermysql.ai.ml.basermysql.ai.ml.modelrmysql.ai.utilsrmysql.connector.abstractsrr rrrrs