Skip to content

Commit 8fea913

Browse files
robvetrobvet
committed
Initial commit
0 parents  commit 8fea913

13 files changed

+1512
-0
lines changed

‎.vs/SynapseFunctionApp/DesignTimeBuild/.dtbcache.v2

117 KB
Binary file not shown.

‎.vs/SynapseFunctionApp/config/applicationhost.config

+1,011
Large diffs are not rendered by default.

‎.vs/SynapseFunctionApp/v16/.suo

46.5 KB
Binary file not shown.

‎SynapseFunctionApp.sln

+25
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,25 @@
1+
2+
Microsoft Visual Studio Solution File, Format Version 12.00
3+
# Visual Studio Version 16
4+
VisualStudioVersion = 16.0.31402.337
5+
MinimumVisualStudioVersion = 10.0.40219.1
6+
Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "SynapseFunctionApp", "SynapseFunctionApp\SynapseFunctionApp.csproj", "{5100979D-52D5-499C-B6C1-C59BEA94E006}"
7+
EndProject
8+
Global
9+
GlobalSection(SolutionConfigurationPlatforms) = preSolution
10+
Debug|Any CPU = Debug|Any CPU
11+
Release|Any CPU = Release|Any CPU
12+
EndGlobalSection
13+
GlobalSection(ProjectConfigurationPlatforms) = postSolution
14+
{5100979D-52D5-499C-B6C1-C59BEA94E006}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
15+
{5100979D-52D5-499C-B6C1-C59BEA94E006}.Debug|Any CPU.Build.0 = Debug|Any CPU
16+
{5100979D-52D5-499C-B6C1-C59BEA94E006}.Release|Any CPU.ActiveCfg = Release|Any CPU
17+
{5100979D-52D5-499C-B6C1-C59BEA94E006}.Release|Any CPU.Build.0 = Release|Any CPU
18+
EndGlobalSection
19+
GlobalSection(SolutionProperties) = preSolution
20+
HideSolutionNode = FALSE
21+
EndGlobalSection
22+
GlobalSection(ExtensibilityGlobals) = postSolution
23+
SolutionGuid = {7D3FEA30-7693-40A7-8943-D24B7FC5D4DB}
24+
EndGlobalSection
25+
EndGlobal

‎SynapseFunctionApp/.gitignore

+264
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,264 @@
1+
## Ignore Visual Studio temporary files, build results, and
2+
## files generated by popular Visual Studio add-ons.
3+
4+
# Azure Functions localsettings file
5+
local.settings.json
6+
7+
# User-specific files
8+
*.suo
9+
*.user
10+
*.userosscache
11+
*.sln.docstates
12+
13+
# User-specific files (MonoDevelop/Xamarin Studio)
14+
*.userprefs
15+
16+
# Build results
17+
[Dd]ebug/
18+
[Dd]ebugPublic/
19+
[Rr]elease/
20+
[Rr]eleases/
21+
x64/
22+
x86/
23+
bld/
24+
[Bb]in/
25+
[Oo]bj/
26+
[Ll]og/
27+
28+
# Visual Studio 2015 cache/options directory
29+
.vs/
30+
# Uncomment if you have tasks that create the project's static files in wwwroot
31+
#wwwroot/
32+
33+
# MSTest test Results
34+
[Tt]est[Rr]esult*/
35+
[Bb]uild[Ll]og.*
36+
37+
# NUNIT
38+
*.VisualState.xml
39+
TestResult.xml
40+
41+
# Build Results of an ATL Project
42+
[Dd]ebugPS/
43+
[Rr]eleasePS/
44+
dlldata.c
45+
46+
# DNX
47+
project.lock.json
48+
project.fragment.lock.json
49+
artifacts/
50+
51+
*_i.c
52+
*_p.c
53+
*_i.h
54+
*.ilk
55+
*.meta
56+
*.obj
57+
*.pch
58+
*.pdb
59+
*.pgc
60+
*.pgd
61+
*.rsp
62+
*.sbr
63+
*.tlb
64+
*.tli
65+
*.tlh
66+
*.tmp
67+
*.tmp_proj
68+
*.log
69+
*.vspscc
70+
*.vssscc
71+
.builds
72+
*.pidb
73+
*.svclog
74+
*.scc
75+
76+
# Chutzpah Test files
77+
_Chutzpah*
78+
79+
# Visual C++ cache files
80+
ipch/
81+
*.aps
82+
*.ncb
83+
*.opendb
84+
*.opensdf
85+
*.sdf
86+
*.cachefile
87+
*.VC.db
88+
*.VC.VC.opendb
89+
90+
# Visual Studio profiler
91+
*.psess
92+
*.vsp
93+
*.vspx
94+
*.sap
95+
96+
# TFS 2012 Local Workspace
97+
$tf/
98+
99+
# Guidance Automation Toolkit
100+
*.gpState
101+
102+
# ReSharper is a .NET coding add-in
103+
_ReSharper*/
104+
*.[Rr]e[Ss]harper
105+
*.DotSettings.user
106+
107+
# JustCode is a .NET coding add-in
108+
.JustCode
109+
110+
# TeamCity is a build add-in
111+
_TeamCity*
112+
113+
# DotCover is a Code Coverage Tool
114+
*.dotCover
115+
116+
# NCrunch
117+
_NCrunch_*
118+
.*crunch*.local.xml
119+
nCrunchTemp_*
120+
121+
# MightyMoose
122+
*.mm.*
123+
AutoTest.Net/
124+
125+
# Web workbench (sass)
126+
.sass-cache/
127+
128+
# Installshield output folder
129+
[Ee]xpress/
130+
131+
# DocProject is a documentation generator add-in
132+
DocProject/buildhelp/
133+
DocProject/Help/*.HxT
134+
DocProject/Help/*.HxC
135+
DocProject/Help/*.hhc
136+
DocProject/Help/*.hhk
137+
DocProject/Help/*.hhp
138+
DocProject/Help/Html2
139+
DocProject/Help/html
140+
141+
# Click-Once directory
142+
publish/
143+
144+
# Publish Web Output
145+
*.[Pp]ublish.xml
146+
*.azurePubxml
147+
# TODO: Comment the next line if you want to checkin your web deploy settings
148+
# but database connection strings (with potential passwords) will be unencrypted
149+
#*.pubxml
150+
*.publishproj
151+
152+
# Microsoft Azure Web App publish settings. Comment the next line if you want to
153+
# checkin your Azure Web App publish settings, but sensitive information contained
154+
# in these scripts will be unencrypted
155+
PublishScripts/
156+
157+
# NuGet Packages
158+
*.nupkg
159+
# The packages folder can be ignored because of Package Restore
160+
**/packages/*
161+
# except build/, which is used as an MSBuild target.
162+
!**/packages/build/
163+
# Uncomment if necessary however generally it will be regenerated when needed
164+
#!**/packages/repositories.config
165+
# NuGet v3's project.json files produces more ignoreable files
166+
*.nuget.props
167+
*.nuget.targets
168+
169+
# Microsoft Azure Build Output
170+
csx/
171+
*.build.csdef
172+
173+
# Microsoft Azure Emulator
174+
ecf/
175+
rcf/
176+
177+
# Windows Store app package directories and files
178+
AppPackages/
179+
BundleArtifacts/
180+
Package.StoreAssociation.xml
181+
_pkginfo.txt
182+
183+
# Visual Studio cache files
184+
# files ending in .cache can be ignored
185+
*.[Cc]ache
186+
# but keep track of directories ending in .cache
187+
!*.[Cc]ache/
188+
189+
# Others
190+
ClientBin/
191+
~$*
192+
*~
193+
*.dbmdl
194+
*.dbproj.schemaview
195+
*.jfm
196+
*.pfx
197+
*.publishsettings
198+
node_modules/
199+
orleans.codegen.cs
200+
201+
# Since there are multiple workflows, uncomment next line to ignore bower_components
202+
# (https://github.com/github/gitignore/pull/1529#issuecomment-104372622)
203+
#bower_components/
204+
205+
# RIA/Silverlight projects
206+
Generated_Code/
207+
208+
# Backup & report files from converting an old project file
209+
# to a newer Visual Studio version. Backup files are not needed,
210+
# because we have git ;-)
211+
_UpgradeReport_Files/
212+
Backup*/
213+
UpgradeLog*.XML
214+
UpgradeLog*.htm
215+
216+
# SQL Server files
217+
*.mdf
218+
*.ldf
219+
220+
# Business Intelligence projects
221+
*.rdl.data
222+
*.bim.layout
223+
*.bim_*.settings
224+
225+
# Microsoft Fakes
226+
FakesAssemblies/
227+
228+
# GhostDoc plugin setting file
229+
*.GhostDoc.xml
230+
231+
# Node.js Tools for Visual Studio
232+
.ntvs_analysis.dat
233+
234+
# Visual Studio 6 build log
235+
*.plg
236+
237+
# Visual Studio 6 workspace options file
238+
*.opt
239+
240+
# Visual Studio LightSwitch build output
241+
**/*.HTMLClient/GeneratedArtifacts
242+
**/*.DesktopClient/GeneratedArtifacts
243+
**/*.DesktopClient/ModelManifest.xml
244+
**/*.Server/GeneratedArtifacts
245+
**/*.Server/ModelManifest.xml
246+
_Pvt_Extensions
247+
248+
# Paket dependency manager
249+
.paket/paket.exe
250+
paket-files/
251+
252+
# FAKE - F# Make
253+
.fake/
254+
255+
# JetBrains Rider
256+
.idea/
257+
*.sln.iml
258+
259+
# CodeRush
260+
.cr/
261+
262+
# Python Tools for Visual Studio (PTVS)
263+
__pycache__/
264+
*.pyc

‎SynapseFunctionApp/Function1.cs

+62
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,62 @@
1+
using System;
2+
using System.IO;
3+
using System.Net;
4+
using System.Threading.Tasks;
5+
using Microsoft.AspNetCore.Http;
6+
using Microsoft.AspNetCore.Mvc;
7+
using Microsoft.Azure.WebJobs;
8+
using Microsoft.Azure.WebJobs.Host;
9+
using Microsoft.Extensions.Logging;
10+
using Microsoft.WindowsAzure.Storage.Blob;
11+
using Microsoft.Azure.WebJobs.Extensions.Http;
12+
13+
namespace SynapseFunctionApp
14+
{
15+
public static class Function1
16+
{
17+
[FunctionName("Function1")]
18+
// Add retry capabilties to the function:
19+
// //https://docs.microsoft.com/en-us/azure/azure-functions/functions-bindings-error-pages?tabs=csharp
20+
//[ExponentialBackoffRetry(3, "00:00:03", "00:12:00")] // Expontentail back retry
21+
public static async void Run([BlobTrigger("dataingest/{name}", Connection = "blobConnectionString")] Stream myBlob,
22+
[Blob("samplefedfile/{name}", FileAccess.ReadWrite, Connection = "synapseConnectionString")]CloudBlobContainer blobContainer,
23+
string name, ILogger log)
24+
{
25+
// Log metadata
26+
log.LogInformation($"Blob trigger invoked: Name:{name}");
27+
28+
// Capture blob name (name of csv file)
29+
var blobName = name;
30+
31+
// Create target container if not exist
32+
33+
// Ensure that target Synapse DataLake blob container exists
34+
if (!await blobContainer.ExistsAsync())
35+
{
36+
log.LogError($"Data Lake container does not exist");
37+
38+
// Data Lake container must exist, or exit function
39+
throw new FunctionException($"Data Lake container does not exist");
40+
//await blobContainer.CreateIfNotExistsAsync();
41+
42+
// Container does not exist -- throw
43+
//return new NotFoundObjectResult("Azure Synapse DataLake container does not exist");
44+
}
45+
46+
try
47+
{
48+
var cloudBlockBlob = blobContainer.GetBlockBlobReference(blobName);
49+
//var photoBytes = Convert.FromBase64String(request.Photo);
50+
//await cloudBlockBlob.UploadFromByteArrayAsync(photoBytes, 0, photoBytes.Length);
51+
await cloudBlockBlob.UploadFromStreamAsync(myBlob);
52+
}
53+
catch (Exception ex)
54+
{
55+
log.LogError($"Exception encountered uploading stream: {ex.Message}");
56+
throw new FunctionException($"Exception encountered: {ex.Message}");
57+
}
58+
59+
log.LogInformation($"Blob {name} successfully written");
60+
}
61+
}
62+
}

‎SynapseFunctionApp/Properties/PublishProfiles/mudfunapp - Zip Deploy.pubxml

+18
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,18 @@
1+
<?xml version="1.0" encoding="utf-8"?>
2+
<!--
3+
https://go.microsoft.com/fwlink/?LinkID=208121.
4+
-->
5+
<Project ToolsVersion="4.0" xmlns="http://schemas.microsoft.com/developer/msbuild/2003">
6+
<PropertyGroup>
7+
<WebPublishMethod>ZipDeploy</WebPublishMethod>
8+
<PublishProvider>AzureWebSite</PublishProvider>
9+
<LastUsedBuildConfiguration>Release</LastUsedBuildConfiguration>
10+
<LastUsedPlatform>Any CPU</LastUsedPlatform>
11+
<SiteUrlToLaunchAfterPublish>http://mudfunapp.azurewebsites.us</SiteUrlToLaunchAfterPublish>
12+
<LaunchSiteAfterPublish>False</LaunchSiteAfterPublish>
13+
<ResourceId>/subscriptions/684590cd-c753-447d-aa20-652457d1629f/resourceGroups/Synapse/providers/Microsoft.Web/sites/mudfunapp</ResourceId>
14+
<UserName>$mudfunapp</UserName>
15+
<_SavePWD>True</_SavePWD>
16+
<PublishUrl>https://mudfunapp.scm.azurewebsites.us/</PublishUrl>
17+
</PropertyGroup>
18+
</Project>

0 commit comments

Comments
 (0)