Azure 함수를 테이블 저장소에 저장

Question

저는 Azure 함수를 가지고 있으며 EventHub에서 메시지를 가져 와서 (이 작업은 매우 간단하고 효과적입니다) 런타임에 테이블 바인딩을 사용하여 해당 정보를 테이블 저장소에 저장하려고합니다. 여기

는 지금까지이 작업은 다음과 같습니다

public static async Task Run(string eventHubMessage, TraceWriter log, Binder binder) 
{ 
    var m = JsonConvert.DeserializeObject<Measurement>(eventHubMessage); 
    var attributes = new Attribute[] 
    { 
     new StorageAccountAttribute("AzureWebJobsTest"), 
     new TableAttribute(tableName, m.PartitionKey, m.RowKey) 
    }; 

    using(var output = await binder.BindAsync<MyTableEntity>(attributes)) 
    { 
     if(output == null) 
      log.Info($"4. output is null"); 
     else 
     { 
      output.Minimum = m.Minimum; 
      output.Maximum = m.Maximum; 
      output.Average = m.Average; 
      output.Timestamp = m.Timestamp; 
      output.ETag = m.ETag; 

      output.WriteEntity(/* Need an operationContext*/) 
     } 
    } 
} 
public class MyTableEntity : TableEntity, IDisposable 
{ 
    public double Average { get; set;} 
    public double Minimum { get; set;} 
    public double Maximum { get; set;} 

    bool disposed = false; 
    public void Dispose() 
    { 
     Dispose(true); 
     GC.SuppressFinalize(this);   
    } 

    protected virtual void Dispose(bool disposing) 
    { 
     if (disposed) 
     return; 

     if (disposing) 
     { 
     } 

     disposed = true; 
    } 
} 

내 문제;

1) 출력은 이고 항상입니다.

2) 출력이 null이 아니더라도 OperationContext에 필요한 항목이나 ITableEntity.Write()를 호출하여 테이블 저장소에 쓸 수있는 올바른 방법인지 알 수 없습니다.

ETA JSON 바인딩 :

{ 
    "bindings": [ 
    { 
     "type": "eventHubTrigger", 
     "name": "eventHubMessage", 
     "direction": "in", 
     "path": "measurements", 
     "connection": "MeasurementsConnectionString" 
    } 
    ], 
    "disabled": false 
} 

Answer 1

가 대신 개체 자체의 IAsyncCollector에 결합한다 표에 새 항목을 추가하려면, 새로운 엔티티를 생성하고 AddAsync를 호출합니다. 다음 스 니펫은 나를 위해 작동합니다.

var attributes = new Attribute[] 
{ 
    new StorageAccountAttribute("..."), 
    new TableAttribute("...") 
}; 

var output = await binder.BindAsync<IAsyncCollector<MyTableEntity>>(attributes);  
await output.AddAsync(new MyTableEntity() 
{ 
    PartitionKey = "...", 
    RowKey = "...", 
    Minimum = ..., 
    ... 
});