-
Notifications
You must be signed in to change notification settings - Fork 2
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
1 parent
2bffac7
commit d6300cc
Showing
5 changed files
with
1,821 additions
and
1,580 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
203 changes: 203 additions & 0 deletions
203
...m/azure/resourcemanager/appservice/samples/ManageLinuxWebAppStorageAccountConnection.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,203 @@ | ||
| // Copyright (c) Microsoft Corporation. All rights reserved. | ||
| // Licensed under the MIT License. | ||
|
|
||
| package com.azure.resourcemanager.appservice.samples; | ||
|
|
||
| import com.azure.core.credential.TokenCredential; | ||
| import com.azure.core.http.HttpClient; | ||
| import com.azure.core.management.AzureEnvironment; | ||
| import com.azure.identity.DefaultAzureCredentialBuilder; | ||
| import com.azure.resourcemanager.AzureResourceManager; | ||
| import com.azure.resourcemanager.appservice.models.ConnectionStringType; | ||
| import com.azure.resourcemanager.appservice.models.PricingTier; | ||
| import com.azure.resourcemanager.appservice.models.RuntimeStack; | ||
| import com.azure.resourcemanager.appservice.models.WebApp; | ||
| import com.azure.core.management.Region; | ||
| import com.azure.core.management.profile.AzureProfile; | ||
| import com.azure.resourcemanager.resources.fluentcore.utils.ResourceManagerUtils; | ||
| import com.azure.resourcemanager.samples.Utils; | ||
| import com.azure.resourcemanager.storage.models.StorageAccount; | ||
| import com.azure.core.http.policy.HttpLogDetailLevel; | ||
| import com.azure.storage.blob.BlobClient; | ||
| import com.azure.storage.blob.BlobContainerClient; | ||
| import com.azure.storage.blob.BlobContainerClientBuilder; | ||
| import com.azure.storage.blob.models.BlobAccessPolicy; | ||
| import com.azure.storage.blob.models.BlobSignedIdentifier; | ||
| import com.azure.storage.blob.models.PublicAccessType; | ||
|
|
||
| import java.io.BufferedInputStream; | ||
| import java.io.File; | ||
| import java.io.FileInputStream; | ||
| import java.io.IOException; | ||
| import java.io.InputStream; | ||
| import java.time.Duration; | ||
| import java.time.OffsetDateTime; | ||
| import java.util.Collections; | ||
|
|
||
|
|
||
| /** | ||
| * Azure App Service basic sample for managing web apps. | ||
| * - Create a storage account and upload a couple blobs | ||
| * - Create a web app that contains the connection string to the storage account | ||
| * - Deploy a Tomcat application that reads from the storage account | ||
| * - Clean up | ||
| */ | ||
| public final class ManageLinuxWebAppStorageAccountConnection { | ||
|
|
||
| /** | ||
| * Main function which runs the actual sample. | ||
| * @param azureResourceManager instance of the azure client | ||
| * @return true if sample runs successfully | ||
| */ | ||
| public static boolean runSample(AzureResourceManager azureResourceManager) { | ||
| // New resources | ||
| final String suffix = ".azurewebsites.net"; | ||
| final String app1Name = Utils.randomResourceName(azureResourceManager, "webapp1-", 20); | ||
| final String app1Url = app1Name + suffix; | ||
| final String storageName = Utils.randomResourceName(azureResourceManager, "jsdkstore", 20); | ||
| final String containerName = Utils.randomResourceName(azureResourceManager, "jcontainer", 20); | ||
| final String rgName = Utils.randomResourceName(azureResourceManager, "rg1NEMV_", 24); | ||
|
|
||
| try { | ||
|
|
||
| //============================================================ | ||
| // Create a storage account for the web app to use | ||
|
|
||
| System.out.println("Creating storage account " + storageName + "..."); | ||
|
|
||
| StorageAccount storageAccount = azureResourceManager.storageAccounts().define(storageName) | ||
| .withRegion(Region.US_WEST) | ||
| .withNewResourceGroup(rgName) | ||
| .create(); | ||
|
|
||
| String accountKey = storageAccount.getKeys().get(0).value(); | ||
|
|
||
| String connectionString = String.format("DefaultEndpointsProtocol=https;AccountName=%s;AccountKey=%s", | ||
| storageAccount.name(), accountKey); | ||
|
|
||
| System.out.println("Created storage account " + storageAccount.name()); | ||
|
|
||
| //============================================================ | ||
| // Upload a few files to the storage account blobs | ||
|
|
||
| System.out.println("Uploading 2 blobs to container " + containerName + "..."); | ||
|
|
||
| BlobContainerClient container = setUpStorageAccount(connectionString, containerName, storageAccount.manager().httpPipeline().getHttpClient()); | ||
| uploadFileToContainer(container, "helloworld.war", ManageLinuxWebAppStorageAccountConnection.class.getResource("/helloworld.war").getPath()); | ||
| uploadFileToContainer(container, "install_apache.sh", ManageLinuxWebAppStorageAccountConnection.class.getResource("/install_apache.sh").getPath()); | ||
|
|
||
| System.out.println("Uploaded 2 blobs to container " + container.getBlobContainerName()); | ||
|
|
||
| //============================================================ | ||
| // Create a web app with a new app service plan | ||
|
|
||
| System.out.println("Creating web app " + app1Name + "..."); | ||
|
|
||
| // note: the env variable will not work in linux since dot is not allowed in env variable name | ||
| WebApp app1 = azureResourceManager.webApps().define(app1Name) | ||
| .withRegion(Region.US_WEST) | ||
| .withExistingResourceGroup(rgName) | ||
| .withNewLinuxPlan(PricingTier.STANDARD_S1) | ||
| .withBuiltInImage(RuntimeStack.TOMCAT_8_5_JRE8) | ||
| .withConnectionString("storage.connectionString", connectionString, ConnectionStringType.CUSTOM) | ||
| .withAppSetting("storage.containerName", containerName) | ||
| .create(); | ||
|
|
||
| System.out.println("Created web app " + app1.name()); | ||
| Utils.print(app1); | ||
|
|
||
| //============================================================ | ||
| // Deploy a web app that connects to the storage account | ||
| // Source code: https://github.com/jianghaolu/azure-samples-blob-explorer | ||
|
|
||
| System.out.println("Deploying azure-samples-blob-traverser.war to " + app1Name + " through FTP..."); | ||
|
|
||
| Utils.uploadFileViaFtp(app1.getPublishingProfile(), "azure-samples-blob-traverser.war", ManageLinuxWebAppStorageAccountConnection.class.getResourceAsStream("/azure-samples-blob-traverser.war")); | ||
|
|
||
| System.out.println("Deployment azure-samples-blob-traverser.war to web app " + app1.name() + " completed"); | ||
| Utils.print(app1); | ||
|
|
||
| // warm up | ||
| System.out.println("Warming up " + app1Url + "/azure-samples-blob-traverser..."); | ||
| Utils.sendGetRequest("http://" + app1Url + "/azure-samples-blob-traverser/"); | ||
| ResourceManagerUtils.sleep(Duration.ofSeconds(5)); | ||
| System.out.println("CURLing " + app1Url + "/azure-samples-blob-traverser..."); | ||
| System.out.println(Utils.sendGetRequest("http://" + app1Url + "/azure-samples-blob-traverser/")); | ||
|
|
||
| return true; | ||
| } finally { | ||
| try { | ||
| System.out.println("Deleting Resource Group: " + rgName); | ||
| azureResourceManager.resourceGroups().beginDeleteByName(rgName); | ||
| System.out.println("Deleted Resource Group: " + rgName); | ||
| } catch (NullPointerException npe) { | ||
| System.out.println("Did not create any resources in Azure. No clean up is necessary"); | ||
| } catch (Exception g) { | ||
| g.printStackTrace(); | ||
| } | ||
| } | ||
| } | ||
| /** | ||
| * Main entry point. | ||
| * @param args the parameters | ||
| */ | ||
| public static void main(String[] args) { | ||
|
|
||
| try { | ||
|
|
||
| //============================================================= | ||
| // Authenticate | ||
|
|
||
| final AzureProfile profile = new AzureProfile(AzureEnvironment.AZURE); | ||
| final TokenCredential credential = new DefaultAzureCredentialBuilder() | ||
| .authorityHost(profile.getEnvironment().getActiveDirectoryEndpoint()) | ||
| .build(); | ||
|
|
||
| AzureResourceManager azureResourceManager = AzureResourceManager | ||
| .configure() | ||
| .withLogLevel(HttpLogDetailLevel.BASIC) | ||
| .authenticate(credential, profile) | ||
| .withDefaultSubscription(); | ||
|
|
||
| // Print selected subscription | ||
| System.out.println("Selected subscription: " + azureResourceManager.subscriptionId()); | ||
|
|
||
| runSample(azureResourceManager); | ||
| } catch (Exception e) { | ||
| System.out.println(e.getMessage()); | ||
| e.printStackTrace(); | ||
| } | ||
| } | ||
|
|
||
| private static BlobContainerClient setUpStorageAccount(String connectionString, String containerName, HttpClient httpClient) { | ||
| BlobContainerClient blobContainerClient = new BlobContainerClientBuilder() | ||
| .connectionString(connectionString) | ||
| .containerName(containerName) | ||
| .httpClient(httpClient) | ||
| .buildClient(); | ||
|
|
||
| blobContainerClient.create(); | ||
|
|
||
| BlobSignedIdentifier identifier = new BlobSignedIdentifier() | ||
| .setId("webapp") | ||
| .setAccessPolicy(new BlobAccessPolicy() | ||
| .setStartsOn(OffsetDateTime.now()) | ||
| .setExpiresOn(OffsetDateTime.now().plusDays(7)) | ||
| .setPermissions("rl")); | ||
|
|
||
| blobContainerClient.setAccessPolicy(PublicAccessType.CONTAINER, Collections.singletonList(identifier)); | ||
|
|
||
| return blobContainerClient; | ||
| } | ||
|
|
||
| private static void uploadFileToContainer(BlobContainerClient blobContainerClient, String fileName, String filePath) { | ||
| BlobClient blobClient = blobContainerClient.getBlobClient(fileName); | ||
| File file = new File(filePath); | ||
| try (InputStream is = new BufferedInputStream(new FileInputStream(file))) { | ||
| blobClient.upload(is, file.length()); | ||
| } catch (IOException e) { | ||
| System.out.println(e.getMessage()); | ||
| e.printStackTrace(); | ||
| } | ||
| } | ||
| } |
Oops, something went wrong.