@@ -105,7 +105,7 @@ app = func.FunctionApp()
105
105
@app.cosmos_db_input (
106
106
arg_name = " documents" , database_name = " <DB_NAME>" ,
107
107
collection_name = " <COLLECTION_NAME>" ,
108
- connection_string_setting = " AzureWebJobsStorage " )
108
+ connection_string_setting = " CONNECTION_SETTING " )
109
109
def cosmosdb_input (req : func.HttpRequest, documents : func.DocumentList) -> str :
110
110
return func.HttpResponse(documents[0 ].to_json())
111
111
```
@@ -120,7 +120,7 @@ import azure.functions as func
120
120
arg_name = " documents" , database_name = " <DB_NAME>" ,
121
121
collection_name = " <COLLECTION_NAME>" ,
122
122
create_if_not_exists = True ,
123
- connection_string_setting = " AzureWebJobsStorage " )
123
+ connection_string_setting = " CONNECTION_SETTING " )
124
124
def main (req : func.HttpRequest, documents : func.Out[func.Document]) -> func.HttpResponse:
125
125
request_body = req.get_body()
126
126
documents.set(func.Document.from_json(request_body))
@@ -137,7 +137,7 @@ import azure.functions as func
137
137
app = func.FunctionApp()
138
138
@app.function_name (name = " EventHubTrigger1" )
139
139
@app.event_hub_message_trigger (arg_name = " myhub" , event_hub_name = " samples-workitems" ,
140
- connection = " " AzureWebJobsStorage " " )
140
+ connection = " " CONNECTION_SETTING " " )
141
141
def test_function (myhub : func.EventHubEvent):
142
142
logging.info(' Python EventHub trigger processed an event: %s ' ,
143
143
myhub.get_body().decode(' utf-8' ))
@@ -153,7 +153,7 @@ app = func.FunctionApp()
153
153
@app.route (route = " eventhub_output" )
154
154
@app.event_hub_output (arg_name = " event" ,
155
155
event_hub_name = " samples-workitems" ,
156
- connection = " AzureWebJobsStorage " )
156
+ connection = " CONNECTION_SETTING " )
157
157
def eventhub_output (req : func.HttpRequest, event : func.Out[str ]):
158
158
body = req.get_body()
159
159
if body is not None :
@@ -230,7 +230,7 @@ import logging
230
230
import azure.functions as func
231
231
app = func.FunctionApp()
232
232
@app.function_name (name = " ServiceBusQueueTrigger1" )
233
- @app.service_bus_queue_trigger (arg_name = " msg" , queue_name = " myinputqueue" , connection = " AzureWebJobsStorage " )
233
+ @app.service_bus_queue_trigger (arg_name = " msg" , queue_name = " myinputqueue" , connection = " CONNECTION_SETTING " )
234
234
def test_function (msg : func.ServiceBusMessage):
235
235
logging.info(' Python ServiceBus queue trigger processed message: %s ' ,
236
236
msg.get_body().decode(' utf-8' ))
@@ -243,7 +243,7 @@ import logging
243
243
import azure.functions as func
244
244
app = func.FunctionApp()
245
245
@app.function_name (name = " ServiceBusTopicTrigger1" )
246
- @app.service_bus_topic_trigger (arg_name = " message" , topic_name = " mytopic" , connection = " AzureWebJobsStorage " , subscription_name = " testsub" )
246
+ @app.service_bus_topic_trigger (arg_name = " message" , topic_name = " mytopic" , connection = " CONNECTION_SETTING " , subscription_name = " testsub" )
247
247
def test_function (message : func.ServiceBusMessage):
248
248
message_body = message.get_body().decode(" utf-8" )
249
249
logging.info(" Python ServiceBus topic trigger processed message." )
@@ -259,7 +259,7 @@ app = func.FunctionApp()
259
259
@app.route (route = " put_message" )
260
260
@app.service_bus_topic_output (
261
261
arg_name = " message" ,
262
- connection = " AzureWebJobsStorage " ,
262
+ connection = " CONNECTION_SETTING " ,
263
263
topic_name = " mytopic" )
264
264
def main (req : func.HttpRequest, message : func.Out[str ]) -> func.HttpResponse:
265
265
input_msg = req.params.get(' message' )
0 commit comments