您现在访问的是微软AZURE全球版技术文档网站,若需要访问由世纪互联运营的MICROSOFT AZURE中国区技术文档网站,请访问 https://docs.azure.cn.

Client class

IoT Hub device client used to connect a device with an Azure IoT hub. Users of the SDK should call one of the factory methods, fromConnectionString or fromSharedAccessSignature to create an IoT Hub device client.

Extends
InternalClient

Constructors

Client(DeviceTransport, string, BlobUploadClient)

Methods

abandon(Message)
abandon(Message, Callback<MessageAbandoned>)
close()

Closes the transport connection and destroys the client resources. Note: After calling this method the Client object cannot be reused.

close(Callback<Disconnected>)

Closes the transport connection and destroys the client resources. Note: After calling this method the Client object cannot be reused.

complete(Message)
complete(Message, Callback<MessageCompleted>)
fromAuthenticationProvider(AuthenticationProvider, any)

Creates an IoT Hub device client from the given authentication method and using the given transport type.

fromConnectionString(string, any)

Creates an IoT Hub device client from the given connection string using the given transport type.

fromSharedAccessSignature(string, any)

Creates an IoT Hub device client from the given shared access signature using the given transport type.

getTwin()
getTwin(Callback<Twin>)
onDeviceMethod(string, (request: DeviceMethodRequest, response: DeviceMethodResponse) => void)

Registers a callback for a method named methodName.

open()
open(Callback<Connected>)
reject(Message)
reject(Message, Callback<MessageRejected>)
sendEvent(Message)
sendEvent(Message, Callback<MessageEnqueued>)
sendEventBatch(Message[])
sendEventBatch(Message[], Callback<MessageEnqueued>)
setOptions(DeviceClientOptions)
setOptions(DeviceClientOptions, Callback<TransportConfigured>)
setRetryPolicy(RetryPolicy)

Sets the retry policy used by the client on all operations. The default is ExponentialBackoffWithJitter.

setTransportOptions(any)
setTransportOptions(any, Callback<TransportConfigured>)
updateSharedAccessSignature(string, Callback<SharedAccessSignatureUpdated>)
uploadToBlob(string, Stream, number)

The uploadToBlob method uploads a stream to a blob.

uploadToBlob(string, Stream, number, ErrorCallback)

The uploadToBlob method uploads a stream to a blob.

Constructor Details

Client(DeviceTransport, string, BlobUploadClient)

new Client(transport: DeviceTransport, connStr?: string, blobUploadClient?: BlobUploadClient)

Parameters

transport
DeviceTransport

An object that implements the interface expected of a transport object, e.g., Http.

connStr
string

A connection string (optional: when not provided, updateSharedAccessSignature must be called to set the SharedAccessSignature token directly).

blobUploadClient
BlobUploadClient

An object that is capable of uploading a stream to a blob.

Method Details

abandon(Message)

function abandon(message: Message)

Parameters

message
Message

Returns

Promise<MessageAbandoned>

abandon(Message, Callback<MessageAbandoned>)

function abandon(message: Message, abandonCallback: Callback<MessageAbandoned>)

Parameters

message
Message
abandonCallback
Callback<MessageAbandoned>

close()

Closes the transport connection and destroys the client resources. Note: After calling this method the Client object cannot be reused.

function close()

Returns

Promise<Disconnected>

close(Callback<Disconnected>)

Closes the transport connection and destroys the client resources. Note: After calling this method the Client object cannot be reused.

function close(closeCallback: Callback<Disconnected>)

Parameters

closeCallback
Callback<Disconnected>

complete(Message)

function complete(message: Message)

Parameters

message
Message

Returns

Promise<MessageCompleted>

complete(Message, Callback<MessageCompleted>)

function complete(message: Message, completeCallback: Callback<MessageCompleted>)

Parameters

message
Message
completeCallback
Callback<MessageCompleted>

fromAuthenticationProvider(AuthenticationProvider, any)

Creates an IoT Hub device client from the given authentication method and using the given transport type.

static function fromAuthenticationProvider(authenticationProvider: AuthenticationProvider, transportCtor: any)

Parameters

authenticationProvider
AuthenticationProvider

Object used to obtain the authentication parameters for the IoT hub.

transportCtor
any

Transport protocol used to connect to IoT hub.

Returns

fromConnectionString(string, any)

Creates an IoT Hub device client from the given connection string using the given transport type.

static function fromConnectionString(connStr: string, transportCtor: any)

Parameters

connStr
string

A connection string which encapsulates "device connect" permissions on an IoT hub.

transportCtor
any

A transport constructor.

Returns

fromSharedAccessSignature(string, any)

Creates an IoT Hub device client from the given shared access signature using the given transport type.

static function fromSharedAccessSignature(sharedAccessSignature: string, transportCtor: any)

Parameters

sharedAccessSignature
string

A shared access signature which encapsulates "device connect" permissions on an IoT hub.

transportCtor
any

Returns

getTwin()

function getTwin()

Returns

Promise<Twin>

getTwin(Callback<Twin>)

function getTwin(done: Callback<Twin>)

Parameters

done
Callback<Twin>

onDeviceMethod(string, (request: DeviceMethodRequest, response: DeviceMethodResponse) => void)

Registers a callback for a method named methodName.

function onDeviceMethod(methodName: string, callback: (request: DeviceMethodRequest, response: DeviceMethodResponse) => void)

Parameters

methodName
string

Name of the method that will be handled by the callback

callback
(request: DeviceMethodRequest, response: DeviceMethodResponse) => void

Function that shall be called whenever a method request for the method called methodName is received.

open()

function open()

Returns

Promise<Connected>

open(Callback<Connected>)

function open(openCallback: Callback<Connected>)

Parameters

openCallback
Callback<Connected>

reject(Message)

function reject(message: Message)

Parameters

message
Message

Returns

Promise<MessageRejected>

reject(Message, Callback<MessageRejected>)

function reject(message: Message, rejectCallback: Callback<MessageRejected>)

Parameters

message
Message
rejectCallback
Callback<MessageRejected>

sendEvent(Message)

function sendEvent(message: Message)

Parameters

message
Message

Returns

Promise<MessageEnqueued>

sendEvent(Message, Callback<MessageEnqueued>)

function sendEvent(message: Message, sendEventCallback: Callback<MessageEnqueued>)

Parameters

message
Message
sendEventCallback
Callback<MessageEnqueued>

sendEventBatch(Message[])

function sendEventBatch(messages: Message[])

Parameters

messages
Message[]

Returns

Promise<MessageEnqueued>

sendEventBatch(Message[], Callback<MessageEnqueued>)

function sendEventBatch(messages: Message[], sendEventBatchCallback: Callback<MessageEnqueued>)

Parameters

messages
Message[]
sendEventBatchCallback
Callback<MessageEnqueued>

setOptions(DeviceClientOptions)

function setOptions(options: DeviceClientOptions)

Parameters

Returns

Promise<TransportConfigured>

setOptions(DeviceClientOptions, Callback<TransportConfigured>)

function setOptions(options: DeviceClientOptions, done: Callback<TransportConfigured>)

Parameters

done
Callback<TransportConfigured>

setRetryPolicy(RetryPolicy)

Sets the retry policy used by the client on all operations. The default is ExponentialBackoffWithJitter.

function setRetryPolicy(policy: RetryPolicy)

Parameters

policy
RetryPolicy

The retry policy that should be used for all future operations.

setTransportOptions(any)

function setTransportOptions(options: any)

Parameters

options
any

Returns

Promise<TransportConfigured>

setTransportOptions(any, Callback<TransportConfigured>)

function setTransportOptions(options: any, done: Callback<TransportConfigured>)

Parameters

options
any
done
Callback<TransportConfigured>

updateSharedAccessSignature(string, Callback<SharedAccessSignatureUpdated>)

function updateSharedAccessSignature(sharedAccessSignature: string, updateSasCallback?: Callback<SharedAccessSignatureUpdated>)

Parameters

sharedAccessSignature
string
updateSasCallback
Callback<SharedAccessSignatureUpdated>

uploadToBlob(string, Stream, number)

The uploadToBlob method uploads a stream to a blob.

function uploadToBlob(blobName: string, stream: Stream, streamLength: number)

Parameters

blobName
string
stream
Stream
streamLength
number

Returns

Promise<void>

uploadToBlob(string, Stream, number, ErrorCallback)

The uploadToBlob method uploads a stream to a blob.

function uploadToBlob(blobName: string, stream: Stream, streamLength: number, callback: ErrorCallback)

Parameters

blobName
string

The name to use for the blob that will be created with the content of the stream.

stream
Stream

The data to that should be uploaded to the blob.

streamLength
number

The size of the data to that should be uploaded to the blob.

callback
ErrorCallback