Merge pull request #8 from devsapp/add-fail-destination

unzip fail can trigger dest fail function as a callback

publish.yaml

@@ -1,6 +1,6 @@
 Type: Application
 Name: start-unzip-oss
-Version: 0.0.15
+Version: 0.0.16
 Provider:
   - 阿里云
 Description: 使用函数计算自动解压上传到OSS指定前缀目录的zip文件

src/fail/index.py

@@ -0,0 +1,10 @@
+# -*- coding: utf-8 -*-
+import logging
+
+
+def handler(event, context):
+    logger = logging.getLogger()
+    logger.info('destnation fail: {}'.format(event))
+    # do your things
+    # ...
+    return {}

src/s.yaml

@@ -46,9 +46,9 @@ services:
           RETAIN_FILE_NAME: "{{ retainFileName }}"
         # 如果是很大的 ZIP 文件， 想使用异步调用，可以开启如下配置,  将每次函数调用看做一个任务执行
         asyncConfiguration:
-          # destination:
-          #   onSuccess: acs:fc:::services/${vars.service.name}/functions/dest-succ
-          #   onFailure: acs:fc:::services/${vars.service.name}/functions/dest-fail
+          destination:
+            #   onSuccess: acs:fc:::services/${vars.service.name}/functions/dest-succ
+            onFailure: acs:fc:::services/${vars.service.name}/functions/dest-fail
           maxAsyncEventAgeInSeconds: 7200
           maxAsyncRetryAttempts: 3
           statefulInvocation: true
@@ -67,3 +67,17 @@ services:
                 Prefix: "{{ prefix }}"
                 Suffix: .zip
             bucketName: "{{ bucketName }}"
+
+  dest-fail:
+    component: fc
+    props:
+      region: ${vars.region}
+      service: ${vars.service}
+      function:
+        name: dest-fail
+        description: "async task destination fail function by serverless devs"
+        runtime: python3
+        codeUri: ./fail
+        handler: index.handler
+        memorySize: 512
+        timeout: 60