Databricks Databricks-Machine-Learning-Professional Dumps

To enable MLflow Autologging for all supported machine learning libraries in a notebook, you can use the mlflow.autolog() function. This function enables autologging for each library by invoking the corresponding autologging function, such as mlflow.sklearn.autolog() or mlflow.spark.autolog(). This way, you do not need to call each autologging function separately. The mlflow.autolog() function also takes care of the compatibility and configuration issues that may arise from different versions of the Databricks Runtime for Machine Learning or workspace-wide settings in the Admin Console. The other options are incorrect because:

• Option A: mlflow.sklearn.autolog() will only enable autologging for scikit-learn, not for other libraries.
• Option B: mlflow.spark.autolog() will only enable autologging for Spark MLlib, not for other libraries.
• Option C: spark.conf.set(“autologging”, True) is not a valid way to enable autologging, as there is no such configuration option in Spark.
• Option D: It is possible to automatically log MLflow runs using the autologging functions provided by MLflow. References: Automatic Logging with MLflow Tracking, MLflow quickstart (Python)

To view all of the active MLflow Model Registry Webhooks for a specific model, the machine learning engineer needs to replace POST with GET in the call to http request. This is because the HTTP method for listing webhooks is GET, not POST. The GET method is used to retrieve information from the server, while the POST method is used to send data to the server1. The syntax of the http request function is as follows:

Python

http_request(host_creds, endpoint, method, json=None, headers=None)

AI-generated code. Review and use carefully. More info on FAQ.

The other options are incorrect because:

• Option A: There are no necessary changes is incorrect, as the code block will not work with the POST method.
• Option B: Replace list with view in the endpoint URL is incorrect, as the endpoint URL for listing webhooks is “/api/2.0/mlflow/registry/webhooks/list?model_name=model”, not “/api/2.0/mlflow/registry/webhooks/view?model_name=model”. There is no view endpoint for webhooks2.
• Option D: Replace list with webhooks in the endpoint URL is incorrect, as the endpoint URL for listing webhooks is “/api/2.0/mlflow/registry/webhooks/list?model_name=model”, not “/api/2.0/mlflow/registry/webhooks/webhooks?model_name=model”. The list keyword is required to specify the list operation2.
• Option E: Replace POST with PUT in the call to http request is incorrect, as the HTTP method for listing webhooks is GET, not PUT. The PUT method is used to update data on the server, not to retrieve information1. References: HTTP request methods, List webhooks

A pyfunc model is a generic Python model that can be loaded and used to make predictions using any Python ML library. By logging a custom model class that implements the preprocessing logic as a pyfunc model, the same logic will be applied when loading the model and calling the predict method on new data. This ensures consistency and reproducibility of the model predictions. The fit method is not relevant for loading a logged model, as it is only used for training the model. The pyfunc model does not affect the parallelizability or the need for pipeline-like objects of the model deployment. References: mlflow.pyfunc, Creating custom Pyfunc models

Drift is the change over time in the statistical properties of the data that was used to train a machine learning model. This can cause the model to become less accurate or perform differently than it was designed to1. Drift can be detected by monitoring the statistics of the input and output data over time and comparing them with the baseline statistics from the training data2. Depending on the type and severity of the drift, different responses may be appropriate. Some possible responses are:

• Retraining and deploying a model on more recent data: This can help the model adapt to the changes in the data and improve its performance. However, this may require frequent retraining and deployment cycles, which can be costly and time-consuming. Also, retraining may not be sufficient if the drift is caused by a change in the underlying concept or relationship between the input and output variables3.
• Rebuilding the machine learning application with a new label variable: This can help the model capture the new concept or relationship that has emerged in the data. However, this may require a significant redesign of the application and the data pipeline, as well as collecting and labeling new data. Also, rebuilding may not be feasible if the concept or relationship is constantly changing or unknown3.
• Sunsetting the machine learning application: This can help avoid the risks and costs of maintaining a model that is no longer reliable or useful. However, this may mean losing the benefits and value of the application and the data. Also, sunsetting may not be an option if the application is critical or mandatory for the business or the users3.

Therefore, all of these responses are probable, depending on the situation and the trade-offs involved. References:

• Databricks Machine Learning Professional Exam Guide, Section 4: Solution and Data Monitoring, p. 5
• Databricks Machine Learning Documentation, Monitoring ML Models, Data Drift Detection, p. 2-3
• A Gentle Introduction to Concept Drift in Machine Learning, Types of Concept Drift, p. 3-4
• Understanding Data Drift and Model Drift: Drift Detection in Python, Types of Drift, p. 2-3

Feature drift, also known as data drift or covariate shift, occurs when the distribution of the input data changes over time, but the relationship between the input and the output remains the same. In this scenario, the expected temperature is an input feature that has changed its distribution, but the output (ice cream sales) still depends on the input in the same way. Feature drift can affect the performance of the model if the new data falls outside the range of the training data, as the model may not have learned how to handle such cases. Feature drift can be detected by monitoring the statistics of the input data over time and comparing them with the baseline statistics from the training data. References:

• Databricks Machine Learning Documentation, Monitoring ML Models, Data Drift Detection, p. 2
• A Gentle Introduction to Concept Drift in Machine Learning, Types of Concept Drift, p. 3
• Understanding Data Drift and Model Drift: Drift Detection in Python, Types of Drift, p. 2

The client.delete_registered_model method of the MlflowClient class can be used to delete a model from the MLflow Model Registry. The method takes the following parameter:

• name: The name of the registered model to delete.

The method deletes the registered model and all its versions from the Model Registry. The method does not return any value1

The other options are incorrect because:

• A. The client.transition_model_version_stage method can be used to transition a model version to a different stage, such as None, Staging, Production, or Archived. The method does not delete the model or the model version from the Model Registry2
• B. The client.delete_model_version method can be used to delete a specific model version from the Model Registry. The method does not delete the registered model or all its versions from the Model Registry3
• C. The client.update_registered_model method can be used to update the metadata of a registered model, such as its name or description. The method does not delete the model or its versions from the Model Registry4
• D. There is no method called client.delete_model. To delete a model from the Model Registry, the client.delete_registered_model method should be used.

References:

• mlflow.tracking.client.MlflowClient.delete_registered_model — MLflow 2.9.1 documentation
• mlflow.tracking.client.MlflowClient.transition_model_version_stage — MLflow 2.9.1 documentation
• mlflow.tracking.client.MlflowClient.delete_model_version — MLflow 2.9.1 documentation
• mlflow.tracking.client.MlflowClient.update_registered_model — MLflow 2.9.1 documentation

MLflow provides a module called mlflow.shap that can be used to automatically calculate and log a Shapley feature importance plot using the SHAP library. The mlflow.shap.log_explanation function takes a predict function and a sample of input data, and computes the SHAP values and base values for each feature. It then logs the following artifacts to the current run:

• Base values
• SHAP values (computed using shap.KernelExplainer)
• Summary bar plot (shows the average impact of each feature on model output) The mlflow.shap.log_explanation function can be used with any model that has a predict function, such as scikit-learn, xgboost, etc1234 References:
• mlflow.shap — MLflow 2.9.1 documentation
• Extract feature importance from a mlflow 1.9 PyFuncModel model
• 9.6 SHAP (SHapley Additive exPlanations) | Interpretable Machine Learning
• load MLFlow model and plot feature importance with feature names

To replace all data in a feature table with newly computed data, you can use the fs.write_table method with the mode argument set to “overwrite”. This will overwrite the existing data in the feature table with the data in the provided DataFrame. The other options are incorrect because:

• Option A: fs.create_table will create a new feature table, not replace the data in an existing one. If the feature table already exists, it will raise an exception.
• Option B: fs.write_table without specifying the mode argument will use the default mode of “merge”, which will merge the new data with the existing data, not replace it.
• Option C: fs.write table is not a valid method name, as it is missing an underscore. Also, the mode argument of “merge” will not replace the data, but merge it with the existing data.
• Option E: fs.create_table with the mode argument of “merge” is not a valid combination, as the mode argument is only applicable for fs.write_table. Also, the mode argument of “merge” will not replace the data, but merge it with the existing data. References: Databricks FeatureStoreClient, Work with features in Workspace Feature Store

The python_function model flavor is a generic model interface for MLflow Python models. It ensures that any MLflow Python model can be loaded and interacted with using a consistent API, regardless of which library was used to create the model. The python_function model flavor defines a standard format for model data and a common interface for model inference. The model data consists of a predict function that can accept various types of input data and return various types of output data. The model inference interface consists of a load_pyfunc function that can load the model from a given path and return an object with a predict method. The python_function model flavor enables model portability and interoperability across different platforms and environments, as it allows deployment tools to understand and use the model without having to integrate with each library-specific model flavor12

The other options are incorrect because:

• A. python_function provides several benefits over the built-in library-specific model flavors, such as portability, interoperability, and simplicity.
• B. python_function does not directly enable parallelizable deployment of models, as it depends on the underlying implementation of the predict function and the deployment tool. However, python_function can be used with other tools and frameworks that support parallelizable deployment, such as Spark, Databricks, or Ray.
• D. python_function is not used to store models in an MLmodel file, but rather to load models from an MLmodel file. The MLmodel file is a configuration file that contains metadata about the model, such as the model flavor, the data path, the dependencies, etc. The MLmodel file is created when the model is logged or saved using MLflow3
• E. python_function does not directly enable deployment of models in batch, streaming, or real-time environments, as it depends on the underlying implementation of the predict function and the deployment tool. However, python_function can be used with other tools and frameworks that support different deployment scenarios, such as MLflow Serving, MLflow Projects, MLflow Models, or MLflow Model Registry4

References:

• mlflow.pyfunc — MLflow 2.9.1 documentation
• Models, Flavors, and PyFuncs in MLflow
• MLflow Models — MLflow 2.9.1 documentation
• Built-In Deployment Tools - MLflow 2.9.1 documentation

Real-time deployment is a type of model deployment where predictions are computed on-demand at query time. This can be useful when the feature values are not available until the time of delivery, and results are needed exceedingly fast for one record at a time. Real-time deployment can leverage Databricks Model Serving, which allows users to host MLflow models as REST endpoints on Databricks1. The other options are incorrect because they either do not meet the requirements or are not supported by Databricks Machine Learning. Edge/on-device deployment is a type of model deployment where predictions are computed on the edge device, such as a smartphone or a sensor. This can be useful when there is limited or no network connectivity, or when privacy and security are important. However, edge deployment is not supported by Databricks Machine Learning2. Streaming deployment is a type of model deployment where predictions are computed on streaming data, such as sensor readings or web logs. This can be useful when the data volume is high and the results need to be updated continuously. However, streaming deployment is not supported by Databricks Model Serving1. Batch deployment is a type of model deployment where predictions are computed in advance and stored for later use. This can be useful when the feature values are known ahead of time and the predictions do not need to be delivered quickly. However, batch deployment does not meet the requirements of this scenario, as the feature values are not available until the time of delivery, and results are needed exceedingly fast for one record at a time. References: MLflow Model Serving, Model deployment patterns

Categorical feature drift is a change in the distribution of the input data over time for categorical features, which can affect the performance and accuracy of the model. Monitoring categorical feature drift is important to ensure that the model is still valid and reliable for the current data. One simple statistic to monitor for categorical feature drift is the combination of mode, number of unique values, and percentage of missing values for each categorical feature. These statistics can provide a quick overview of the changes in the data distribution, such as the most frequent category, the diversity of categories, and the quality of data. If these statistics deviate significantly from the baseline values, it may indicate a categorical feature drift. However, these statistics may not capture all the nuances of the data distribution, such as the relative frequencies of different categories, the similarity of categories, etc. Therefore, other methods, such as statistical tests or information-theoretic measures, may be needed to complement the simple statistics and provide a more comprehensive analysis of the categorical feature drift123 References:

• Monitoring Feature Drift - Databricks
• Drift Metrics: How to Select the Right Metric to Analyze Drift
• Detect data drift on datasets (preview) - Azure Machine Learning

The mlflow.register_model operation can be used to add a new version of an MLflow Model to an existing MLflow Model Registry model. This operation takes the URI of the model source (such as an MLflow run or a local path) and the name of the registered model as arguments, and returns a ModelVersion object that contains metadata about the registered model version. The mlflow.register_model operation can also create a new registered model if the name does not exist in the Model Registry.

The other options are incorrect for the following reasons:

• B. MlflowClient.update_registered_model is used to update the metadata of an existing registered model, such as the name or description, not to add a new version of the model.
• C. mlflow.add_model_version does not exist as a valid MLflow operation.
• D. MlflowClient.get_model_version is used to fetch the metadata of a specific version of a registered model, not to add a new version of the model.
• E. The machine learning engineer does not need to create an entirely new MLflow Model Registry model, as they can use the mlflow.register_model operation to add a new version of the model to the existing “project” model.

References: Adding an MLflow Model to the Model Registry, mlflow.register_model

To obtain run-level results for an experiment ID in a Spark DataFrame, you can use the mlflow.search_runs(exp_id) function. This function takes a filter string, which acts as a filter to the query, and returns a pandas.DataFrame of runs, where each metric, parameter, and tag are expanded into their own columns named metrics., params., and tags.* respectively1. You can then convert the pandas.DataFrame to a Spark DataFrame using the spark.createDataFrame() method2. The other options are incorrect because:

• Option A: client.list_run_infos(exp_id) will return a list of RunInfo objects, not a DataFrame3.
• Option B: spark.read.format(“delta”).load(exp_id) will not work for MLflow experiments, as it expects a Delta table path, not an experiment ID4.
• Option C: There is a way to programmatically return row-level results from an MLflow experiment using the mlflow.search_runs(exp_id) function1.
• Option E: spark.read.format(“mlflow-experiment”).load(exp_id) is not a valid format for reading MLflow experiments, as there is no such format registered in Spark5. References: Search Runs, Create a DataFrame from an RDD, a list or a pandas.DataFrame, MlflowClient.list_run_infos, Delta Lake Quickstart, spark.read.format

 The mlflow.register_model function takes two arguments: model_uri and name. The model_uri is the URI of the model that was logged to MLflow, which can be obtained from the best run object. The name is the name of the registered model in the MLflow Model Registry. Therefore, the correct line of code to register the model is:

mlflow.register_model(model_uri, “best_model”)

This will create a new registered model with the name “best_model” and register the model version from the best run as the first version of that model.

References:

• [mlflow.register_model — MLflow 1.22.0 documentation]
• [MLflow Model Registry — Databricks Documentation]
• [Manage MLflow Models — Databricks Documentation] Message has links.

Concept drift is a change in the relationship between input and output data over time, which can affect the performance and accuracy of the model. To monitor concept drift, one needs to compare the predicted values from the model with the observed (actual) label values from the data source. A common way to do this is to compute an evaluation metric, such as accuracy, precision, recall, F1-score, etc., using the observed and predicted values. This metric can indicate how well the model is performing on the current data, and how it differs from the baseline performance on the training data. If the metric shows a significant decline over time, it may suggest that concept drift has occurred and the model needs to be updated123 References:

• Monitoring Concept Drift - Databricks
• Data drift, concept drift, and how to monitor for them - Mona Labs
• 8 Concept Drift Detection Methods To Use With ML Models - Aporia

To drop a column from a Delta table, you need to enable column mapping mode for the table and use the ALTER TABLE statement with the DROP COLUMN clause. Alternatively, you can use the spark.read.format(“delta”).table(path) method to read the Delta table as a DataFrame and then use the drop method to drop the column. This will return a new DataFrame with the column removed. You can then overwrite the originalDelta table with the new DataFrame using the write.format(“delta”).mode(“overwrite”) method. The other options are incorrect because:

• Option A: spark.read.format(“delta”).load(path) will not read the Delta table as a table, but as a directory of files. This will not preserve the schema and metadata of the table, and will not allow you to overwrite the table with the new DataFrame.
• Option C: Delta tables can be modified using the Delta Lake APIs or SQL commands. Delta Lake supports schema evolution and column mapping to enable dropping columns from Delta tables.
• Option D: spark.read.table(path) will not work for Delta tables, as it expects a table name, not a path. To read a Delta table by its path, you need to use the spark.read.format(“delta”).load(path) or spark.read.format(“delta”).table(path) methods.
• Option E: spark.sql(“SELECT * EXCEPT star_rating FROM path”) will not drop the column from the Delta table, but only return a new DataFrame with the column excluded. This will not affect the original Delta table, and will not allow you to overwrite the table with the new DataFrame. References: Drop columns, Delta Lake Quickstart, Delta Lake column mapping

Containers are a type of software packaging that can assist in real-time deployments by packaging software with its own application, tools, and libraries. Containers are isolated and portable environments that run on a shared operating system, but have their ownfile system, dependencies, configuration, and resources. Containers can help developers and operators to build, test, and deploy software faster, easier, and more reliably, as they ensure that the software runs the same way in any environment, whether it is a developer’s laptop, a test server, or a production cluster. Containers can also help to achieve scalability, high availability, and load balancing, as they can be easily created, destroyed, replicated, and orchestrated using tools such as Kubernetes, Docker Swarm, or Amazon ECS. Containers can also integrate with other tools and services, such as MLflow, Databricks, AWS CodeDeploy, and Google Cloud Deployment Manager, to enable end-to-end machine learning pipelines with tracking, reproducibility, and governance1234 References:

• How to Package Your Application’s Infrastructure with Docker
• 21 open source DevOps tools (and what they do)
• Microservices [What is it & Top Benefits]
• 9 Best Software Deployment Tools for 2023 (Paid & Free)

Concept drift in machine learning and data mining refers to the change in the relationships between input and output data in the underlying problem over time. In other domains, this change maybe called “covariate shift,” “dataset shift,” or “nonstationarity.” Concept drift can affect the performance and accuracy of predictive models that assume a static relationship between input and output variables. Concept drift can be caused by various factors, such as changes in user behavior, environmental conditions, market trends, etc. Concept drift can be detected and handled by various methods, such as periodic retraining, online learning, ensemble methods, etc References:

• Concept drift - Wikipedia
• A Gentle Introduction to Concept Drift in Machine Learning
• Model Drift & Machine Learning: Concept Drift, Feature Drift, Etc.
• Data Drift vs. Concept Drift: What Is the Difference?