in Microsoft.Azure.WebJobs.Extensions.AzureCosmosDb.Mongo/Trigger/CosmosDBMongoTriggerBindingProvider.cs [26:47]
public Task<ITriggerBinding> TryCreateAsync(TriggerBindingProviderContext context)
{
if (context == null)
throw new ArgumentNullException("context");
var attribute = context.Parameter.GetCustomAttribute<CosmosDBMongoTriggerAttribute>(inherit: false);
if (attribute == null)
{
return Task.FromResult<ITriggerBinding>(null);
}
string connectionString = _configProvider.ResolveConnectionString(attribute.ConnectionStringSetting);
string functionId = context.Parameter.Member.Name;
var reference = new MongoCollectionReference(
_configProvider.GetService(connectionString),
ResolveAttributeValue(attribute.DatabaseName),
ResolveAttributeValue(attribute.CollectionName));
reference.functionId = functionId;
return
Task.FromResult<ITriggerBinding>(new CosmosDBMongoTriggerBinding(context.Parameter,
reference,
this._logger));
}