Upload Files into Azure blob storage with ASP.NET Core Web API

 We are going to divide this article into the following sections:

·       Creating Azure Storage

·       Upload Files to Azure with ASP.NET Core Web API

1.       Creating Azure Storage

The first thing we have to do is to navigate and sign in to Azure Portal where we can create our storage. If we don’t have a subscription we can create a free subscription account on the dashboard.

Next, we are going to create a new storage account service:



After these steps, we are going to click the Next button two times until our validation passes:

2.       we are going to modify the appsettings.json file by adding a connection string section:

{

  "ConnectionStrings": {

    "EmployeeAppcon": "Data Source=****.mysql.database.azure.com;initial catalog=databaseName;User id=****; Pwd=***"

    "AzureBlobStorage": "DefaultEndpointsProtocol=https;AccountName=authoringsite;AccountKey=X+5571rJNdsg/T7p8WPsTlG/n+KNACPXzkPshpW59y0L9UDReETid8ncxokMTb7Cml9QBKaOG7HpZ2VgLd3SgA==;EndpointSuffix=core.windows.net"

  },

    "Logging": {

      "LogLevel": {

        "Default": "Information",

        "Microsoft": "Warning",

        "Microsoft.Hosting.Lifetime": "Information"

      }

    },

    "AllowedHosts": "*"

  }

We can find this connection string in the Access keys menu that we already have opened:


3.       Next create a new project in visual studio.


4.       Select ASP.Net Core Web Application.


5.           Provide Project name and location.



6.      Select Target Framework and click on Create button.

7.        Once project is create basic view in solution explore.


8.       We need to create two folder with names controllers and models. 


9.       Need to install dependency from Genet packages.

MySql.Data.dll

Microsoft.AspNetCore.Mvc.NewtonsoftJson.dll – version 3.1.10

Azure.Storage.Blobs – version 12.1.0

10.       Please update below line in startup.js 

            // added scope to azure blob storage

            services.AddScoped(x => new BlobServiceClient(Configuration.GetValue<string>("ConnectionStrings:AzureBlobStorage")));

11.       Next we need to create AssetUploadController.cs


using Azure.Storage.Blobs;

using Azure.Storage.Blobs.Models;

using createwebapiusingmysql.Models;

using Microsoft.AspNetCore.Mvc;

using Microsoft.Extensions.Configuration;

using MySql.Data.MySqlClient;

using System;

using System.Collections.Generic;

using System.Data;

using System.Linq;

using System.Threading.Tasks;

 

namespace createwebapiusingmysql.Controllers

{

    [Route("api/[controller]")]

    [ApiController]

    public class AssetUploadController : Controller

    {

        private readonly string _azureConnectionString;

        private readonly string _azureConnectionStringsastoken;

        private readonly IConfiguration _configuration;

        public AssetUploadController(IConfiguration configuration)

        {

            _azureConnectionString = configuration.GetConnectionString("AzureBlobStorage");

            _azureConnectionStringsastoken = configuration.GetConnectionString("SASToken");

            _configuration = configuration;

        }

        List<Products> _category = new List<Products>();

        [HttpPost("{id}")]

        public async Task<IActionResult> assetAsync(int id)

        {

 

            try

            {

                GetcategoryFriendlyame(id);

                string containersname = _category[0].categoryFriendlyame;

                var formCollection = await Request.ReadFormAsync();

                var file = formCollection.Files.First();

                if (file.Length > 0)

                {

                    var container = new BlobContainerClient(_azureConnectionString, containersname);

                    var createResponse = await container.CreateIfNotExistsAsync();

                    if (createResponse != null && createResponse.GetRawResponse().Status == 201)

                        await container.SetAccessPolicyAsync(Azure.Storage.Blobs.Models.PublicAccessType.Blob);

                    var blob = container.GetBlobClient(file.FileName);

 

                    await blob.DeleteIfExistsAsync((Azure.Storage.Blobs.Models.DeleteSnapshotsOption)Azure.Storage.Blobs.Models.DeleteSnapshotsOption.IncludeSnapshots);

                    using (var fileStream = file.OpenReadStream())

                    {

                        await blob.UploadAsync(fileStream, new BlobHttpHeaders { ContentType = file.ContentType });

                        blob.SetMetadata(new Dictionary<string, string>());

                        Dictionary<string, string> metadata = new Dictionary<string, string>(2);

                        metadata.Add("ProductId", id.ToString());

                        blob.SetMetadata(metadata);

                    }

                    if (blob.Uri.ToString() != null && blob.Uri.ToString() != "")

                    {

                        UpdateProductTable(id.ToString(), blob.Uri.ToString());

                    }

                    return Ok(blob.Uri.ToString());

                }

                return BadRequest();

            }

            catch (Exception ex)

            {

                return StatusCode(500, $"Internal server error: {ex}");

            }

        }

        // we are getting category name to create container in azure

        private List<Products> GetcategoryFriendlyame(int id)

        {

            var @ProductId = id;

            string query = @"select categoryFriendlyame,ProductId from restapi.categories,restapi.products where categories.categoryid = products.categoryid AND products.ProductId=" + @ProductId + ";";

            //query = query.Replace("{id}", id);

            DataTable table = new DataTable();

            string sqlDataSource = _configuration.GetConnectionString("EmployeeAppcon");

            MySqlDataReader myReader;

            using (MySqlConnection mycon = new MySqlConnection(sqlDataSource))

            {

                mycon.Open();

                using (MySqlCommand mycommond = new MySqlCommand(query, mycon))

                {

                    //mycommond.Parameters.AddWithValue("@ProductId", id);

                    myReader = mycommond.ExecuteReader();

                    table.Load(myReader);

 

                    myReader.Close();

                    mycon.Close();

                }

 

                for (int i = 0; i < table.Rows.Count; i++)

                {

                    Products prd = new Products();

                    prd.ProductId = Convert.ToInt32(table.Rows[i]["ProductId"]);

                    prd.categoryFriendlyame = table.Rows[i]["categoryFriendlyame"].ToString();

 

                    _category.Add(prd);

                }

                return (_category);

            }

        }

 

        // We are updating image and model url to filed in product table

        private void UpdateProductTable(string v1, string v2)

        {

            string imageuri = v2;

            var splitVals = imageuri.Split('/');

            var URL4 = splitVals[3];

            var URL5 = splitVals[4];

            string subseturi = "https://ceeademocontent.azureedge.net";

            var sastoken = _azureConnectionStringsastoken;

            string finalurl = "" + subseturi + "/" + URL4 + "/" + URL5 + sastoken;

            string imagetype = URL5.Substring(URL5.Length - 4);

            string query;

            if (imagetype.ToString() == "gltf" || imagetype.ToString() == ".glb")

            {

                query = @"update restapi.Products set productModel = '{finalurl}' where productId = {v1}";

                query = query.Replace("{finalurl}", finalurl);

                query = query.Replace("{v1}", v1);

            }

            else

            {

 

                query = @"update restapi.Products set productPreview = '{finalurl}' where productId = {v1}";

                query = query.Replace("{finalurl}", finalurl);

                query = query.Replace("{v1}", v1);

            }

           

            DataTable table = new DataTable();

            string sqlDataSource = _configuration.GetConnectionString("EmployeeAppcon");

            MySqlDataReader myReader;

            using (MySqlConnection mycon = new MySqlConnection(sqlDataSource))

            {

                mycon.Open();

                using (MySqlCommand mycommond = new MySqlCommand(query, mycon))

                {

                    myReader = mycommond.ExecuteReader();

                    table.Load(myReader);

 

                    myReader.Close();

                    mycon.Close();

                }

 

            }

            //return new JsonResult(table);

        }

    }

}



Reference Link:

https://code-maze.com/upload-files-to-azure-aspnet-core-blazor-webassembly/

https://code-maze.com/download-files-from-azure-with-net-core-web-api-and-blazor-webassembly/




































Comments

Post a Comment

Popular posts from this blog

Create Data Package file to Import Or Export CRM records.

Image
  The Microsoft Dynamics CRM 2015 Software Development Kit (SDK) Migration tool is essential for exporting and importing configuration data. It is particularly useful for transferring metadata, customizations, and configurations between environments. Download Link: https://www.microsoft.com/en-in/download/details.aspx?id=44567 After downloading Microsoft Dynamics CRM 2015 Software Development Kit (SDK) unzip and Navigate to MicrosoftDynamicsCRM2015SDK\Tools\ConfigurationMigration. ·        To Open SDK tool MicrosoftDynamicsCRM2015SDK\Tools\ConfigurationMigration\ DataMigrationUtility.exe ·        First, we need to Create Schema. Select on Create Schema and click on continue. ·        It be asked to log in to your source CRM system, Select Display list of available organizations and give your username and passed and logging. ·        Please select your org...
Read more

Receive Incoming Message in Twilio using Power Automate

Image
  In this blog we will learn how to read when an incoming message received in Twilio using Power Automate. ·        Power Automate Flow creation. ·        Configuration power automate flow URL in Twilio.   Power Automate Flow creation. Open https://make.powerapps.com/   and create a new automated flow in Power Automate using the "When an HTTP request is received" trigger. To do this, search for "HTTP" and select the HTTP request trigger, as shown below. Give the required flow name and click on Create. Next add Compose compound and add below formal  to read input from above step. decodeUriComponent(string(triggerBody())) Next to read received message, from number and to number we need each initial variables in flow. From Number add below formal in value:  first(split(split(outputs('Compose'), 'From=')[1], '&')) To Number add below formal in value : first(split(split(ou...
Read more

Azure Function to Read Incoming Message in Twilio

Image
  Introduction In this tutorial, we will learn how to read incoming message in Twilio and respond to webhooks using Azure Functions. We will learn what is webhooks, how to set up an Azure Function, and then use Azure Function app to respond to a Twilio SMS webhook and create a record in dynamic 365 in case entity when new message received. Prerequisites: A Twilio account.  An Azure account with an active subscription. Dynamic365 subscription. What is webhook? Webhook is an HTTP request triggered by an event in a source system and sent to a destination system. To enable this, you provide the source system with a URL where it can send the HTTP request. A typical webhook setup involves the following: A destination system that needs to be notified about a specific event. A source system that sends a notification to the destination system when the event occurs. This system uses the provided webhook URL to make the HTTP request. In your a...
Read more

Open canvas app with Customize the command bar using command designer

Image
  This topic guides you through creating and editing modern commands using the command designer and Power Fx. Create a new model-driven app using modern app designer 1.      Sign into  Power Apps 2.      On the left navigation pane, select  Solutions  and then open or create a solution to contain the new model-driven app. 3.      Select  New  >  App  >  Model-driven app 4.      Select  Modern app designer , and then select  Create .    Enter a  Name  for your app, and then select  Create . More information:  Create a model-driven app that has an account table page 1.      On the left navigation pane, select  Solutions , and then open the solution containing the existing model-driven app. 2.      Select the model-driven app, and then select --  >  Edit ...
Read more

Execute CRUD operations within the Power Platform using a Canvas App

Image
  User story: When a new account is created, there is a requirement to execute a curd operation via Power Apps, involving updating an existing record and deleting the record from the accounts. If we want to few complete records in accounts entity on welcome screen: Navigate to vertical Gallery and select Items property should be Item=Accounts. To create a new record, one must click on the plus icon displayed on the screen and input the formula provided below, as illustrated in the following screen. This action will prompt a new screen to open for the creation of the new record.   Navigate ( CreateScreen ) ; ResetForm ( 'Account Create Form' ) After navigating to the creation screen, a new form will be displayed, and it is necessary to configure the data source to 'Account,' as shown in the screen below. And Items property = Defaults (Accounts) Next, upon clicking the submit button, we should save the data in the account entity and return to the main screen. ...
Read more