AzureQueueStorageConnector
Accesses the Azure Queue Storage service to send or receive messages.
Typical Uses
- Aggregation of data from queues and other message streams
- Trigger an action from a message
How does it work?
The AzureQueueStorageConnector uses your Azure Storage account credentials (either via a previously defined FME web connection, or by setting up a new FME web connection right from the transformer) to access the queue storage service.
Usage Notes
- The queue storage service xml encodes and decodes messages in utf-8 by default
Configuration
Input Ports
This transformer accepts any feature.
Output Ports
The output of this transformer will vary depending on the action performed.Message data and metadata are presented as feature attributes.
- After a接收action, output features represent messages received from the queue.
- After a发送action, output features represent messages sent to the queue.
The incoming feature is output through this port.
Features that cause the operation to fail are output through this port.Anfme_rejection_codeattribute, having the valueERROR_DURING_PROCESSING, will be added, along with a more descriptivefme_rejection_messageattribute which contains more specific details as to the reason for the failure.
注意:如果 a feature comes in to the AzureQueueStorageConnector already having a value forfme_rejection_code, this value will be removed.
Rejected Feature Handling:can be set to either terminate the translation or continue running when it encounters a rejected feature.This setting is available both as a defaultFME option和 as aworkspace parameter。
Parameters
凭据来源 | 以核实身份。使用网络连接整合最好的FME,但在某些情况下,你可能希望使用其他来源之一。
|
帐户 | 当凭证源可用Web连接。要创建一个Azure存储连接,单击“帐户”下拉框,选择“添加网络连接...”。 随后,连接将可以通过管理工具 - > FME选项...- >网络连接。 |
用户名 | 当凭证源可用SAS要么嵌入式。帐户名和任一个帐户密钥或共享访问签名可以直接在变压器中指定。 |
帐户关键字 | 当凭证源可用嵌入式。帐户名和快捷键可以直接在变压器,而不是在网络连接中指定。 |
共享访问签名(SAS) | 当凭证源可用SAS。帐户名和共享访问签名可以直接在变压器中指定。 |
行动 | 的操作类型来执行。选项有:
|
The remaining parameters available depend on the value of the Action > Action parameter.Parameters for each Action are detailed below.
删除s messages from the queue.
删除 Messages Options
队列 |
队列从删除邮件。队列可以手动输入,或者通过点击省略号交互选择。 |
删除所有邮件 |
如果是,队列中的所有消息都将被除去。如果没有时,指定ID和POP接收到该消息将被删除。 |
消息ID |
需要删除的消息。从以前的检索接收操作。 |
POP收据 |
需要删除的消息。从以前的检索接收操作。 |
服务器超时(秒) |
最大的时间来等待服务器完成请求的操作。 |
接收s messages from the front of the queue without altering the visibility of the messages.
窥视 Messages Options
队列 |
该队列,以在从消息偷看。队列可以手动输入,或者通过点击省略号交互选择。 |
消息数 |
消息的数量,以从队列偷看。 |
服务器超时(秒) |
最大的时间来等待服务器完成请求的操作。 |
接收s messages from the front of the queue.
接收 Messages Options
队列 |
队列接收来自消息。队列可以手动输入,或者通过点击省略号交互选择。 |
模式 |
两个消息接收选项:
|
消息数 |
指定的邮件数来读取操作。对于流模式,这是每个轮询间隔检索到的数。对于批量模式,这是检索的总数。 |
轮询间隔(秒) |
当模式流中,周期来接收消息之间等待。 |
删除接收 |
如果是,然后尽快将它们从队列中接收到删除的邮件。如果没有,消息可以再次可见性超时后接收。 |
能见度超时(秒) |
的时间的信息是不可见的。超时到期后,该消息是可见的。默认值是30秒。 |
服务器超时(秒) |
最大的时间来等待服务器完成请求的操作。 |
发送 Messages Options
队列 |
队列从发送消息。队列可以手动输入,或者通过点击省略号交互选择。 |
内容 |
经编码的消息。默认的编码是一个xml unicode字符串。 |
更新信息 |
如果是中,更新队列中的服务的消息。如果工作区没有结束处理此操作可以是“租赁”的消息是有用的。消息的不可见性可以通过更新可见性超时被延长。 |
消息ID |
需要更新的消息。从以前的检索接收操作。 |
POP收据 |
需要更新的消息。从以前的检索接收操作。 |
生存时间到期 |
如果是设置该消息为生活的时间。如果没有中,消息永不过期。 |
生存时间(秒) |
多久消息的生活。默认和最大的为7天。在指定时间后,该消息被永久地从队列中删除。 |
能见度超时(秒) |
的时间的信息是不可见的。超时到期后,该消息是可见的。默认值为0秒。 |
服务器超时(秒) |
最大的时间来等待服务器完成请求的操作。 |
The following attributes can be selected for inclusion on the output features.Each output feature represents a message that was either sent or received.
_ID |
一个消息的ID。所需的更新和删除。 |
_值 |
该消息的内容。 |
_dequeue_count |
的次数的消息已被检索,无论是从窥视或接收操作。 |
_expiration_time |
的时间的消息中UNIX时间到期。 |
_pop_receipt |
的POP接收消息,从获得的接收操作。所需的更新和删除。 |
_time_next_visible |
当时的消息是在UNIX时间下一个可见。 |
_timestamp |
当时的消息是在UNIX时间创建。 |
Editing Transformer Parameters
Using a set of menu options, transformer parameters can be assigned by referencing other elements in the workspace.More advanced functions, such as an advanced editor and an arithmetic editor, are also available in some transformers.To access a menu of these options, clickbeside the applicable parameter.对于 more information, seeTransformer Parameter Menu Options。
Defining Values
There are several ways to define a value for use in a Transformer.The simplest is to simply type in a value or string, which can include functions of various types such as attribute references, math and string functions, and workspace parameters.There are a number of tools and shortcuts that can assist in constructing values, generally available from the drop-down context menu adjacent to the value field.
Using the Text Editor
The Text Editor provides a convenient way to construct text strings (including regular expressions) from various data sources, such as attributes, parameters, and constants, where the result is used directly inside a parameter.
Using the Arithmetic Editor
The Arithmetic Editor provides a convenient way to construct math expressions from various data sources, such as attributes, parameters, and feature functions, where the result is used directly inside a parameter.
Conditional Values
Set values depending on one or more test conditions that either pass or fail.
Parameter Condition Definition Dialog
内容
Expressions and strings can include a number of functions, characters, parameters, and more.
When setting values - whether entered directly in a parameter or constructed using one of the editors - strings and expressions containing String, Math, Date/Time or FME Feature Functions will have those functions evaluated.Therefore, the names of these functions (in the form @<function_name>) should not be used as literal string values.
Reference
加工行为 |
|
特点控股 |
没有 |
依赖 | Azure存储帐户 |
FME许可级别 | FME基础版及以上 |
别名 | MicrosoftAzureQueueStorageConnector |
历史 | 发布FME 2019.0 |
分类 |
FME Community
The FME Community is the place for demos, how-tos, articles, FAQs, and more.Get answers to your questions, learn from other users, and suggest, vote, and comment on new features.
Search forall results about the AzureQueueStorageConnectoron the FME Community.
Examples may contain information licensed under the Open Government Licence – Vancouver