А
Size: a a a
А
SN
SB
SN
SB
А
AH
match op.AccessKey with
| Some connectionString ->
match op.DatabaseId with
| Some dbId ->
match op.ContainerName with
| Some cn ->
match op.Query with
| Some query ->
let client = new CosmosClient(op.Endpoint, connectionString, clientOps)
let db = client.GetDatabase dbId
let container = db.GetContainer cn
let qd = QueryDefinition query
op.Parameters
|> List.map (fun (key, value) -> qd.WithParameter(key, value))
|> ignore
container.GetItemQueryIterator<'T> qd |> AsyncSeq.ofAsyncEnum
| None -> failwith "No query provided"
| None -> failwith "No container name provided"
| None -> failwith "No dabase id provided"
| None -> failwith "No access key provided"
SN
SB
self() ! hi
будет асинхронным: отправка сообщения процессом самому себе. ты имел в виду, сообразит ли эрланг, что надо доставить сообщение на другую ноду?SN
SN
AH
match op.AccessKey with
| Some connectionString ->
match op.DatabaseId with
| Some dbId ->
match op.ContainerName with
| Some cn ->
match op.Query with
| Some query ->
let client = new CosmosClient(op.Endpoint, connectionString, clientOps)
let db = client.GetDatabase dbId
let container = db.GetContainer cn
let qd = QueryDefinition query
op.Parameters
|> List.map (fun (key, value) -> qd.WithParameter(key, value))
|> ignore
container.GetItemQueryIterator<'T> qd |> AsyncSeq.ofAsyncEnum
| None -> failwith "No query provided"
| None -> failwith "No container name provided"
| None -> failwith "No dabase id provided"
| None -> failwith "No access key provided"
AH
SN
AH
SN
AH
AH