azure - 向 Azure 数据流中的文件动态添加时间戳

标签 azure dataflow

我一直在开发一个 azure 项目,我想使用包含时间戳的动态文件名创建一个数据流。 例如,如果输出是文件名 'A' --> 'A_YY-mm-dd_hh_mm_ss' 我已经使用此链接 Here 在数据工厂上做到了这一点 但在这种情况下我不知道如何使用它。 这是我的数据流enter image description here

输入是一个提取文件(我用复制数据完成)

最佳答案

您可以引用this code 。我尝试修改 filenamePrefixForWindow 方法,并且能够实现这一目标。这些是我所做的改变 -

public String filenamePrefixForWindow(IntervalWindow window) {
        Calendar calendar = Calendar.getInstance();
        String year = String.valueOf(calendar.get(Calendar.YEAR));
        String month = String.format("%02d",(calendar.get(Calendar.MONTH)+1));
        String date = String.format("%02d",calendar.get(Calendar.DATE));
        int hh = calendar.get(Calendar.HOUR);
        String hour = String.format("%02d",(calendar.get(Calendar.AM_PM) == 0) ? hh:hh+12);
        String minute = String.format("%02d",calendar.get(Calendar.MINUTE));
        String full_date = year+"-"+month+"-"+date+"-"+hour+"-"+minute;
        String prefix =
                baseFilename.isDirectory() ? "" : baseFilename.getFilename();
        return String.format(
                "%s/%s/%s/%s/%s/output-%s", prefix,year,month,date,hour,full_date);
    }

关于azure - 向 Azure 数据流中的文件动态添加时间戳,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/70086137/

相关文章:

asp.net-mvc - Mvc 捆绑请求返回空白文件

azure - 如何使用Azure PowerShell识别服务类型?

azure - Microsoft 从 oauth2 登录问题

c# - 当消费者不堪重负时,如何让快速生产者暂停?

java - 我收到错误 : "Overload resolution ambiguity" from MapElements transform in Apache Beam when using Kotlin

azure - 在 Azure 应用服务 (Windows) 中递归复制文件夹速度非常慢

c# - 如何在第一个异常时取消整个 tpl 数据流?

hadoop - 运行 NiFi 所需的 Hadoop 配置是什么?

google-cloud-dataflow - 使用 DataFlow 运行程序运行 Beam 作业时出错(使用 Bazel): no module found error

azure - 使用 az apim api 更新 apim 中的 api