访问Azure队列存储服务来发送或接收消息。
典型的使用
- 来自队列和其他消息流的数据聚合
- 从消息触发一个动作
它是如何工作的?
AzureQueueStorageConnector使用您的Azure Storage帐户凭据(通过之前定义的FME网络连接，或者直接从转换器设置一个新的FME网络连接)来访问队列存储服务。
使用笔记
- 队列存储服务xml默认使用utf-8编码和解码消息
配置
输入端口
输入
这个变压器接受任何特性。
输出端口
输出
这个变压器的输出将根据所执行的动作而变化。消息数据和元数据显示为特性属性。
- 后收到操作时，输出特性表示从队列接收的消息。
- 后发送操作时，输出特性表示发送到队列的消息。
引发剂
进入的特性通过这个端口输出。
参数
身份验证
| 凭证来源 | 需要进行身份验证。使用网络连接与FME集成得最好，但在某些情况下，你可能希望使用其他来源之一。
|
| 账户 | 当凭据源为时可用网络连接．要创建Azure Storage连接，请单击“Account”下拉框并选择“Add Web connection…”。 连接可以通过工具管理-> FME选项…——>网络连接。 |
嵌入式的凭证
| 帐户名称 | 当凭据源为时可用情景应用程序或嵌入式．可以在转换器中直接指定帐户名和帐户密钥或共享访问签名。 |
| 账户关键 | 当凭据源为时可用嵌入式．帐户名和访问密钥可以直接在转换器中指定，而不是在web连接中指定。 |
| SAS (Shared Access Signature) | 当凭据源为时可用情景应用程序．可以在转换器中直接指定帐户名和共享访问签名。 |
行动
| 行动 | 要执行的操作类型。的选择是:
|
剩余可用的参数取决于Action > Action参数的值。下面详细介绍每个操作的参数。
参数- - - - - -删除操作
从队列中删除消息。
删除消息选项
队列 |
要从中删除消息的队列。可以手动输入队列，也可以通过单击省略号交互式地选择队列。 |
删除所有消息 |
如果是的，队列中的所有消息将被删除。如果没有，带有指定ID和POP收据的消息将被删除。 |
消息ID |
删除消息时需要。从先前的接收操作中检索。 |
流行的收据 |
删除消息时需要。从先前的接收操作中检索。 |
服务器超时(秒) |
等待服务器完成请求操作的最长时间。 |
参数- - - - - -看行动
从队列的前面接收消息，而不改变消息的可见性。
Peek消息选项
队列 |
用于查看消息的队列。可以手动输入队列，也可以通过单击省略号交互式地选择队列。 |
的消息数量 |
要从队列中偷看的消息的数量。 |
服务器超时(秒) |
等待服务器完成请求操作的最长时间。 |
参数- - - - - -接收操作
从队列前面接收消息。
接收消息选项
队列 |
接收消息的队列。可以手动输入队列，也可以通过单击省略号交互式地选择队列。 |
模式 |
有两个消息接收选项:
|
的消息数量 |
指定操作要读取的消息数。为流模式，这是每个轮询间隔检索的数字。为批处理Mode，这是找回的总数。 |
轮询间隔(秒) |
当模式流，接收消息之间的等待时间。 |
删除在接收 |
如果是的，然后在从队列接收到消息后立即删除消息。如果没有，则在可见性超时后可以再次接收消息。 |
可见性超时(秒) |
时间信息是不可见的。在超时过期后，消息是可见的。默认值是30秒。 |
服务器超时(秒) |
等待服务器完成请求操作的最长时间。 |
参数- - - - - -发送操作
发送消息选项
队列 |
发送消息的队列。可以手动输入队列，也可以通过单击省略号交互式地选择队列。 |
内容 |
一个编码信息。默认编码是xml unicode字符串。 |
更新消息 |
如果是的，更新队列服务中的消息。如果工作区尚未完成处理，此操作对于“租用”消息非常有用。消息的不可见性可以通过更新可见性超时来扩展。 |
消息ID |
更新消息所需。从先前的接收操作中检索。 |
流行的收据 |
更新消息所需。从先前的接收操作中检索。 |
生存时间到期 |
如果是的，设置信息存在的时间。如果没有，信息永远不会过期。 |
生存时间(秒) |
信息的寿命。默认值和最大值是7天。在指定的时间之后，消息将永久地从队列中删除。 |
可见性超时(秒) |
时间信息是不可见的。在超时过期后，消息是可见的。缺省值是0秒。 |
服务器超时(秒) |
等待服务器完成请求操作的最长时间。 |
输出属性
可以选择以下属性以包含在输出特性中。每个输出特性表示发送或接收的消息。
_id |
消息的id。更新和删除所需。 |
_value |
消息内容。 |
_dequeue_count |
从窥视或接收操作检索消息的次数。 |
_expiration_time |
消息在unix时间内过期的时间。 |
_pop_receipt |
从接收操作获得的消息的POP接收。更新和删除所需。 |
_time_next_visible |
在unix时间中，消息下一次可见的时间。 |
_timestamp |
在unix时间内创建消息的时间。 |
编辑变压器参数
使用一组菜单选项，可以通过引用工作空间中的其他元素来分配转换器参数。更高级的函数，如高级编辑器和算术编辑器，也可以在一些转换器中使用。要访问这些选项的菜单，请单击
除适用参数外。有关更多信息，请参见变压器参数菜单选项．
定义值
有几种方法可以定义在Transformer中使用的值。最简单的方法是简单地输入值或字符串，其中可以包括各种类型的函数，如属性引用、数学和字符串函数以及工作空间参数。有许多工具和快捷方式可以帮助构造值，通常可以从值字段附近的下拉上下文菜单中获得。
如何设置参数值
使用文本编辑器
Text Editor提供了一种方便的方法来从各种数据源(如属性、参数和常量)构造文本字符串(包括正则表达式)，其中结果直接在参数中使用。
使用算术编辑器
算术编辑器提供了一种方便的方法来从各种数据源(如属性、参数和功能函数)构造数学表达式，其中结果直接在参数中使用。
有条件的值
根据一个或多个通过或失败的测试条件设置值。
内容
表达式和字符串可以包括许多函数、字符、参数等等。
当设置值时——无论是直接输入参数还是使用其中一个编辑器构造的值——包含String、Math、Date/Time或FME Feature Functions的字符串和表达式将对这些函数进行计算。因此，这些函数的名称(以@<的形式)function_name>)不应该用作字符串的文字值。
参考
处理行为 |
|
功能持有 |
没有 |
| 依赖关系 | Azure存储账户 |
| FME授权级别 | FME基础版及以上 |
| 别名 | MicrosoftAzureQueueStorageConnector |
| 历史 | FME 2019.0发布: |
| 类别 |
FME社亚搏国际在线官网区
FME社区是演示亚搏国际在线官网、操作指南、文章、faq和更多内容的地方。获得问题的答案，向其他用户学习，并对新功能提出建议、投票和评论。
搜索AzureQueueStorageConnector的所有结果在FME社区。亚搏国际在线官网
例子可能包含在开放政府许可证-温哥华下许可的信息