使用 Azure 函数的动态输出 blob 路径

2024-01-06

我有一个由事件中心触发的 Azure 函数。这是我的 index.js 文件的片段。

module.exports = async function (context, eventHubMessages) {
    context.log(`JavaScript eventhub trigger function called for message array ${eventHubMessages}`);

    context.log('Event Hub Trigger: ', JSON.stringify(eventHubMessages));

    const product = context.bindingData.propertiesArray[0].productFilter;

    eventHubMessages.forEach(message =>
    {
      deviceId = message.deviceId;
      context.log('For each message:', JSON.stringify(eventHubMessages));
      context.log('Device ID is', deviceId);
    });
    context.log('Output Device ID is', deviceId);

    if ( product == 'prod1') {


        context.bindings.outputprod1 = eventHubMessages;

    } else if ( product == 'prod2') {

        context.bindings.prod2 = eventHubMessages;
    else {
        context.log("Product not found - " + product);
    }
    return context.done();

};

传入消息中有一个属性deviceId。我想根据这个值设置输出 blob 路径。

这是我的 function.json 文件。

{
  "bindings": [

    {
      "type": "blob",
      "name": "outputprod1",
      "path": "eventtoblobcontainer/prod1/{datetime:yyyy}/{datetime:MM}/{datetime:dd}/prod1_{rand-guid}",
      "connection": "phiotrawdatadev_STORAGE",
      "direction": "out"
    },
    {
      "type": "blob",
      "name": "outputBlobprod2",
      "path": "eventtoblobcontainer/prod2/{datetime:yyyy}/{datetime:MM}/{datetime:dd}/prod2_{rand-guid}",
      "connection": "phiotrawdatadev_STORAGE",
      "direction": "out"
    }
  ]
}

如果我在路径中添加 {deviceId} ,该函数会给出错误,指出命名参数“deviceId”没有值。我尝试在输出绑定中使用函数返回值,但它给了我同样的错误。我怎样才能实现这个目标?


None

本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)

使用 Azure 函数的动态输出 blob 路径 的相关文章

随机推荐

  • 加载 DB2 JDBC 驱动程序时出现 java.lang.UnsatisfiedLinkError

    我尝试将jboss seam与db2数据库一起使用 出现以下错误 com ibm db2 jcc a SqlException jcc 10389 12245 3 52 95 while loading the native library
  • 在Python中,是否有async相当于multiprocessing或concurrent.futures?

    基本上 我正在寻找使用 python3 协程作为后端而不是线程或进程提供并行映射的东西 我相信执行高度并行 IO 工作时应该有更少的开销 当然类似的东西已经存在了 无论是在标准库中还是在一些广泛使用的包中 免责声明 PEP 0492 htt
  • 使用 Typescript 设置 Vue 数据对象中的数据类型

    我目前正在 webpack 项目中使用 Vue js 和 Typescript 如中所示推荐配置 https v2 vuejs org v2 guide typescript html in my tsconfig json I have
  • 将字符串转换为 LatLng

    我正在使用 Google Maps API v2 并且从 SharedPreferences 中获取位置坐标单个字符串 34 8799074 174 7565664 我需要将其转换为 LatLng 有人可以帮忙吗 Thx 谷歌地图Andro
  • Caliburn.Micro 将 MainView 中的 UserControls 绑定到其 ViewModel

    我有一个 MainView xaml 绑定到 MainViewModel 就可以了 我想尝试的是将主窗体上的许多控件拆分为用户控件 现在 我将 UserControls 与 MainView 一起放入 Views 文件夹中 并将它们命名为
  • 我在 KubernetesPodOperator 的 DAG 设置中做错了什么

    我在这个中找到了以下Airflow DAG博客文章 https kubernetes io blog 2018 06 28 airflow on kubernetes part 1 a different kind of operator
  • Spritekit - 创建一堵“墙”

    我想知道如何用 spritekit 创建一堵墙 物体上的某些东西无法移动过去 我知道我可以使用这段代码 self physicsBody SKPhysicsBody bodyWithEdgeLoopFromRect self frame 但
  • JavaScript 对象检测:点语法与“in”关键字

    我见过两种检测 UA 是否实现特定 JS 属性的方法 if object property and if property in object 我想听听关于哪个更好的意见 最重要的是 为什么 其中一个明显优于另一个吗 除了这两种方法之外还有
  • 获取CPU温度

    我想知道CPU的温度 以下是我使用 C 和 WMI 所做的工作 我正在读取 MSAcpi ThermalZoneTemperature 但它始终相同 而且根本不是 CPU 温度 有没有办法不用写驱动就能获取CPU的真实温度 或者有什么我可以
  • OpenXML SDK C++ 示例

    HI 我正在尝试使用 OpenXML SDK 在 C 中创建一个 Word 文档 我在添加引用和使用命名空间时遇到问题 因为网上的大多数示例都是基于 C 给出的 1 如何在代码中添加对项目的引用并使用命名空间 例如 using namesp
  • 邮政信箱验证

    希望验证邮政信箱 但想知道是否存在此类验证 我将 地址 字段分为 地址 1 和 地址 2 此类 PO Apt Suite 信息所在的位置 Example Address 1 123 Main Street Address 2 Suite 1
  • Hadoop MapReduce 出现“无法解析主机名”错误

    现在我运行Hadoop MapReduce作业 输入数据来自HBase表 最近出现错误 错误如下 错误mapreduce TableInputFormatBase 无法解析 172 16 4 195的主机名 因为javax naming N
  • pandas“未命名”列不断出现

    我遇到一个问题 每次运行程序 从 csv 文件读取数据帧 时 都会显示一个名为 未命名 的新列 运行 3 次后的示例输出列 Unnamed 0 Unnamed 0 1 Subreddit Appearances 这是我的代码 对于每一行 未
  • 将按钮添加到 WinForms 的列表视图中

    有没有办法将按钮控件添加到 WinForms 应用程序中 ListView 内的单元格 这是一个类的代码ListViewExtender您可以重复使用 它不是一个派生类ListView 基本上您只需声明特定列显示为按钮而不是文本 按钮的文本
  • 如何在 Asp.Net Identity 中获取用户的角色名称

    我想弄清楚如何在身份框架中查找用户角色名称 我的配置是 只有一个角色分配给用户 所以 我尝试使用 public string GetUserRole string EmailID string Password var user await
  • 如何释放 glBufferData 内存

    我创建了一个顶点缓冲区对象类来管理应用程序中的大量顶点 用户调用构造函数创建glBuffer 并调用glBufferData分配指定大小的空间 有一个名为 resize 的类函数 允许用户通过再次调用 glBufferData 来更改 VB
  • 在响应式中隐藏图像?

    我是引导程序编码的新手CSS我遇到了一个问题 在桌面版本中我需要一个图像 但当涉及到移动版本时 我需要显示第二个图像 而第一个图像应该隐藏 div class col md 9 style padding 0px img src image
  • iPhone:通过给定的 CGPath 剪辑用户提供的 UIImage

    在我的iPhone应用程序中 我需要让用户剪辑用户提供的UIImage通过给定的动态生成CGPath 所有外部给定的 已关闭 CGPath应该被剪掉 并且生成的图像应该被路径的边界矩形修剪 图像应使用软边框进行裁剪 也就是说 剪切路径边缘的
  • Pygame 鼠标事件中的 Python 时间计数器

    我想计算 Pygame 中用户鼠标事件的时间 如果用户大约 15 秒没有移动鼠标 那么我想在屏幕上显示文本 我试过time模块 但它不起作用 import pygame time pygame init codes font pygame
  • 使用 Azure 函数的动态输出 blob 路径

    我有一个由事件中心触发的 Azure 函数 这是我的 index js 文件的片段 module exports async function context eventHubMessages context log JavaScript