subject:"\[GitHub\] zhy989 commented on issue #210\: How to use message feed"

[GitHub] zhy989 commented on issue #210: How to use message feed

2017-08-17 Thread git

zhy989 commented on issue #210: How to use message feed
URL: 
https://github.com/apache/incubator-openwhisk-package-kafka/issues/210#issuecomment-323106472
 
 
   @bjustin-ibm thanks!
   I have tried to set the LOCAL_DEV environment variable to true, it works 
well without modify code, thanks!
 

This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


With regards,
Apache Git Services

[GitHub] zhy989 commented on issue #210: How to use message feed

2017-08-17 Thread git

zhy989 commented on issue #210: How to use message feed
URL: 
https://github.com/apache/incubator-openwhisk-package-kafka/issues/210#issuecomment-323091776
 
 
   @bjustin-ibm thanks?
   The action can be invoked successfully  when I set verify to False from line 
"response = requests.post(self.triggerURL, json=payload, timeout=10.0, 
**verify=False**)" in file 
"incubator-openwhisk-package-kafka/provider/consumer.py"
 

This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


With regards,
Apache Git Services

[GitHub] zhy989 commented on issue #210: How to use message feed

2017-08-17 Thread git

zhy989 commented on issue #210: How to use message feed
URL: 
https://github.com/apache/incubator-openwhisk-package-kafka/issues/210#issuecomment-322977487
 
 
   @bjustin-ibm  thanks 
   I have created the kafka trigger successfully, the reason is the couchdb url 
should be http  not https.
   
   I follow below CLI  
   
   - "docker run -e DB_URL=https://myDbHost -e DB_USER=MyDbUser -e 
DB_PASS=MySuperSecret -p 80:5000 kafkafeedprovider"  
   
   There is a 's' . I remove the 's', the kafka trigger can be created 
successfully.
   
Then I create rule iot1 related MyKafkaTrigger1 and  hello action , when I 
produce a message to kafka, but the helloworld action did not run .  When kafka 
received a message how to trigger the hello action ?
   
   - wsk trigger create MyKafkaTrigger1 -f /whisk.system/messaging/kafkaFeed -p 
brokers "???:9092" -p topic mytopic -p isJSONData true -i
   ok: invoked /whisk.system/messaging/kafkaFeed with id 
0f42764f28794c439eb07ca643990fbc
   {
   "activationId": "0f42764f28794c439eb07ca643990fbc",
   "annotations": [
   {
   "key": "limits",
   "value": {
   "logs": 10,
   "memory": 256,
   "timeout": 6
   }
   },
   {
   "key": "path",
   "value": "whisk.system/messaging/kafkaFeed"
   }
   ],
   "duration": 1191,
   "end": 1502949731923,
   "logs": [],
   "name": "kafkaFeed",
   "namespace": "whisk.system",
   "publish": false,
   "response": {
   "result": {
   "uuid": "f7684a93-c510-43f7-8bea-ab82c4b05877"
   },
   "status": "success",
   "success": true
   },
   "start": 1502949730732,
   "subject": "whisk.system",
   "version": "0.0.10"
   }
   ok: created trigger MyKafkaTrigger1
   
   - wsk -i rule create iot1 MyKafkaTrigger1 hello
   ok: created rule iot1
   
   - wsk action invoke /whisk.system/messaging/kafkaProduce -p brokers 
"???:9092" -p topic mytopic -p value "This is the content of my message" -i
   ok: invoked /whisk.system/messaging/kafkaProduce with id 
5e5ed2151ecd4a79ac2576ee38f0bab3
 

This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


With regards,
Apache Git Services

[GitHub] zhy989 commented on issue #210: How to use message feed

2017-08-16 Thread git

zhy989 commented on issue #210: How to use message feed
URL: 
https://github.com/apache/incubator-openwhisk-package-kafka/issues/210#issuecomment-322681658
 
 
   @bjustin-ibm thanks
   
   Is docker image( kafkafeedprovider) a kafka server ?  
   When I run the docker image (kafkafeedprovider), the service port is  set to 
8081 on the host and 5000 in the container ( -p 8081:5000) .
   
   - docker ps | grep kafka
   da3959a164ddwhisk/nodejs6action:latest   "/bin/sh -c 'node --e"   35 
seconds ago  Up 34 seconds  

wsk0_112_whisksystem_kafkaFeed
   35636cd428f0kafkafeedprovider"/bin/bash -c 'cd Kaf"   22 
hours agoUp 22 hours (healthy)   0.0.0.0:8081->5000/tcp 

focused_meninsky
   
   so when I create the kafka trigger , the brokers is set to localhost:8081, 
is right?
   I have tried brokers (-p localhost:8081), there is also connect error as 
before.
   
   - bin/kafka-topics.sh --list --zookeeper localhost:2181
   __consumer_offsets
   completed
   completed0
   health
   invoker0
   test
   test1
   
   - wsk trigger create MyKafkaTrigger -f /whisk.system/messaging/kafkaFeed -p 
brokers "localhost:8081" -p topic test -p isJSONData true -i
   ok: invoked /whisk.system/messaging/kafkaFeed with id 
9c21eb1067b346d1997433e95728a1c6
   {
   "activationId": "9c21eb1067b346d1997433e95728a1c6",
   "annotations": [
   {
   "key": "limits",
   "value": {
   "logs": 10,
   "memory": 256,
   "timeout": 6
   }
   },
   {
   "key": "path",
   "value": "whisk.system/messaging/kafkaFeed"
   }
   ],
   "duration": 871,
   "end": 1502865968399,
   "logs": [],
   "name": "kafkaFeed",
   "namespace": "whisk.system",
   "publish": false,
   "response": {
   "result": {
   "error": "Error: error happened in your connection"
   },
   "status": "application error",
   "success": false
   },
   "start": 1502865967528,
   "subject": "whisk.system",
   "version": "0.0.3"
   }
   ok: invoked /whisk.system/messaging/kafkaFeed with id 
e6657b45d465419bbfe94c29ff501ac1
   {
   "activationId": "e6657b45d465419bbfe94c29ff501ac1",
   "annotations": [
   {
   "key": "limits",
   "value": {
   "logs": 10,
   "memory": 256,
   "timeout": 6
   }
   },
   {
   "key": "path",
   "value": "whisk.system/messaging/kafkaFeed"
   }
   ],
   "duration": 476,
   "end": 1502865969295,
   "logs": [],
   "name": "kafkaFeed",
   "namespace": "whisk.system",
   "publish": false,
   "response": {
   "result": {},
   "status": "success",
   "success": true
   },
   "start": 1502865968819,
   "subject": "whisk.system",
   "version": "0.0.3"
   }
   ok: deleted trigger MyKafkaTrigger
   Run 'wsk --help' for usage.
   
   - wsk -i activation logs 9c21eb1067b346d1997433e95728a1c6
   2017-08-16T06:46:08.396704825Z stdout: Error creating trigger: {
   2017-08-16T06:46:08.396728812Z stdout: "name": "StatusCodeError",
   2017-08-16T06:46:08.396732511Z stdout: "statusCode": 500,
   2017-08-16T06:46:08.396735284Z stdout: "message": "500 - \"Error: error 
happened in your connection\"",
   2017-08-16T06:46:08.396740819Z stdout: "error": "Error: error happened in 
your connection",
   2017-08-16T06:46:08.396743554Z stdout: "options": {
   2017-08-16T06:46:08.396746034Z stdout: "method": "PUT",
   2017-08-16T06:46:08.396749189Z stdout: "url": 
"https://172.17.0.1/api/v1/web/whisk.system/messagingWeb/kafkaFeedWeb.http;,
   2017-08-16T06:46:08.396751943Z stdout: "rejectUnauthorized": false,
   2017-08-16T06:46:08.396754359Z stdout: "json": true,
   2017-08-16T06:46:08.396756718Z stdout: "body": {
   2017-08-16T06:46:08.396759626Z stdout: "authKey": 
"789c46b1-71f6-4ed5-8c54-816aa4f8c502:abczO3xZCLrMN6v2BKK1dXYFpXlPkccOFqm12CdAsMgRU4VrNZ9lyGVCGuMDGIwP",
   2017-08-16T06:46:08.396762437Z stdout: "isJSONData": true,
   2017-08-16T06:46:08.396764717Z stdout: "brokers": "localhost:8081",
   2017-08-16T06:46:08.396767046Z stdout: "topic": "test",
   2017-08-16T06:46:08.396769378Z stdout: "triggerName": 
"/whisk.system/MyKafkaTrigger"
   2017-08-16T06:46:08.396771913Z stdout: },
   2017-08-16T06:46:08.396774162Z stdout: "headers": {
   2017-08-16T06:46:08.396776529Z stdout: "Content-Type": "application/json",
   2017-08-16T06:46:08.396779016Z stdout: "Accept": "text/plain",

[GitHub] zhy989 commented on issue #210: How to use message feed

2017-08-15 Thread git

zhy989 commented on issue #210: How to use message feed
URL: 
https://github.com/apache/incubator-openwhisk-package-kafka/issues/210#issuecomment-322427182
 
 
   @bjustin-ibm thanks!
   I had run the docker image(kafkafeedprovider) successfully.
   
   then I try to create kafka trigger with CLI :
   - wsk trigger create MyKafkaTrigger -f /whisk.system/messaging/kafkaFeed -p 
brokers "mykafkahost:9092, mykafkahost:9093" -p topic mytopic -p isJSONData 
true -i
   ok: invoked /whisk.system/messaging/kafkaFeed with id 
5c4ec13b87ca48698dbee7dbc7b10e0b
   {
   "activationId": "5c4ec13b87ca48698dbee7dbc7b10e0b",
   "annotations": [
   {
   "key": "limits",
   "value": {
   "logs": 10,
   "memory": 256,
   "timeout": 6
   }
   },
   {
   "key": "path",
   "value": "whisk.system/messaging/kafkaFeed"
   }
   ],
   "duration": 1496,
   "end": 1502790634515,
   "logs": [],
   "name": "kafkaFeed",
   "namespace": "whisk.system",
   "publish": false,
   "response": {
   "result": {
   "error": "Error: error happened in your connection"
   },
   "status": "application error",
   "success": false
   },
   "start": 1502790633019,
   "subject": "whisk.system",
   "version": "0.0.3"
   }
   ok: invoked /whisk.system/messaging/kafkaFeed with id 
111b55bf70e248ba90beca624d0ed123
   {
   "activationId": "111b55bf70e248ba90beca624d0ed123",
   "annotations": [
   {
   "key": "limits",
   "value": {
   "logs": 10,
   "memory": 256,
   "timeout": 6
   }
   },
   {
   "key": "path",
   "value": "whisk.system/messaging/kafkaFeed"
   }
   ],
   "duration": 501,
   "end": 1502790635383,
   "logs": [],
   "name": "kafkaFeed",
   "namespace": "whisk.system",
   "publish": false,
   "response": {
   "result": {},
   "status": "success",
   "success": true
   },
   "start": 1502790634882,
   "subject": "whisk.system",
   "version": "0.0.3"
   }
   ok: deleted trigger MyKafkaTrigger
   Run 'wsk --help' for usage.
   
   It failed , the logs is as below:
   
   - wsk -i activation logs 5c4ec13b87ca48698dbee7dbc7b10e0b
   2017-08-15T09:50:34.511516922Z stdout: Error creating trigger: {
   2017-08-15T09:50:34.511548026Z stdout: "name": "StatusCodeError",
   2017-08-15T09:50:34.511552003Z stdout: "statusCode": 500,
   2017-08-15T09:50:34.511554501Z stdout: "message": "500 - \"Error: error 
happened in your connection\"",
   2017-08-15T09:50:34.511557142Z stdout: "error": "Error: error happened in 
your connection",
   2017-08-15T09:50:34.511559611Z stdout: "options": {
   2017-08-15T09:50:34.511561707Z stdout: "method": "PUT",
   2017-08-15T09:50:34.511564397Z stdout: "url": 
"https://172.17.0.1/api/v1/web/whisk.system/messagingWeb/kafkaFeedWeb.http;,
   2017-08-15T09:50:34.511570175Z stdout: "rejectUnauthorized": false,
   2017-08-15T09:50:34.511572303Z stdout: "json": true,
   2017-08-15T09:50:34.511574498Z stdout: "body": {
   2017-08-15T09:50:34.51157697Z  stdout: "authKey": 
"789c46b1-71f6-4ed5-8c54-816aa4f8c502:abczO3xZCLrMN6v2BKK1dXYFpXlPkccOFqm12CdAsMgRU4VrNZ9lyGVCGuMDGIwP",
   2017-08-15T09:50:34.51158097Z  stdout: "isJSONData": true,
   2017-08-15T09:50:34.511584471Z stdout: "brokers": "mykafkahost:9092, 
mykafkahost:9093",
   2017-08-15T09:50:34.511588192Z stdout: "topic": "mytopic",
   2017-08-15T09:50:34.511591885Z stdout: "triggerName": 
"/whisk.system/MyKafkaTrigger"
   2017-08-15T09:50:34.511595503Z stdout: },
   2017-08-15T09:50:34.511598525Z stdout: "headers": {
   2017-08-15T09:50:34.511602038Z stdout: "Content-Type": "application/json",
   2017-08-15T09:50:34.511605702Z stdout: "Accept": "text/plain",
   2017-08-15T09:50:34.511609225Z stdout: "User-Agent": "whisk"
   2017-08-15T09:50:34.511612934Z stdout: },
   2017-08-15T09:50:34.511618017Z stdout: "simple": true,
   2017-08-15T09:50:34.511621631Z stdout: "resolveWithFullResponse": false,
   2017-08-15T09:50:34.511625174Z stdout: "transform2xxOnly": false
   2017-08-15T09:50:34.511628593Z stdout: },
   2017-08-15T09:50:34.511631863Z stdout: "response": {
   2017-08-15T09:50:34.511635333Z stdout: "statusCode": 500,
   2017-08-15T09:50:34.511639172Z stdout: "body": "Error: error happened in 
your connection",
   2017-08-15T09:50:34.511643199Z stdout: "headers": {
   2017-08-15T09:50:34.511646877Z stdout: "server": "nginx/1.11.13",
   2017-08-15T09:50:34.511650606Z stdout: "date": "Tue, 15 Aug 2017 09:50:34 
GMT",
   2017-08-15T09:50:34.511654232Z stdout: "content-type": "text/plain",
   2017-08-15T09:50:34.511657958Z stdout: "content-length": "40",
   2017-08-15T09:50:34.511665314Z stdout: "connection": "close",

[GitHub] zhy989 commented on issue #210: How to use message feed

2017-08-15 Thread git

zhy989 commented on issue #210: How to use message feed
URL: 
https://github.com/apache/incubator-openwhisk-package-kafka/issues/210#issuecomment-322427182
 
 
   @bjustin-ibm thanks!
   I had run the docker image(kafkafeedprovider) successfully.
   
   then I try to create kafka trigger with CLI :
   - wsk trigger create MyKafkaTrigger -f /whisk.system/messaging/kafkaFeed -p 
brokers "mykafkahost:9092, mykafkahost:9093" -p topic mytopic -p isJSONData 
true -i
   ok: invoked /whisk.system/messaging/kafkaFeed with id 
5c4ec13b87ca48698dbee7dbc7b10e0b
   {
   "activationId": "5c4ec13b87ca48698dbee7dbc7b10e0b",
   "annotations": [
   {
   "key": "limits",
   "value": {
   "logs": 10,
   "memory": 256,
   "timeout": 6
   }
   },
   {
   "key": "path",
   "value": "whisk.system/messaging/kafkaFeed"
   }
   ],
   "duration": 1496,
   "end": 1502790634515,
   "logs": [],
   "name": "kafkaFeed",
   "namespace": "whisk.system",
   "publish": false,
   "response": {
   "result": {
   "error": "Error: error happened in your connection"
   },
   "status": "application error",
   "success": false
   },
   "start": 1502790633019,
   "subject": "whisk.system",
   "version": "0.0.3"
   }
   ok: invoked /whisk.system/messaging/kafkaFeed with id 
111b55bf70e248ba90beca624d0ed123
   {
   "activationId": "111b55bf70e248ba90beca624d0ed123",
   "annotations": [
   {
   "key": "limits",
   "value": {
   "logs": 10,
   "memory": 256,
   "timeout": 6
   }
   },
   {
   "key": "path",
   "value": "whisk.system/messaging/kafkaFeed"
   }
   ],
   "duration": 501,
   "end": 1502790635383,
   "logs": [],
   "name": "kafkaFeed",
   "namespace": "whisk.system",
   "publish": false,
   "response": {
   "result": {},
   "status": "success",
   "success": true
   },
   "start": 1502790634882,
   "subject": "whisk.system",
   "version": "0.0.3"
   }
   ok: deleted trigger MyKafkaTrigger
   Run 'wsk --help' for usage.
   
   It failed , the logs is as below:
   
   - wsk -i activation logs 5c4ec13b87ca48698dbee7dbc7b10e0b
   2017-08-15T09:50:34.511516922Z stdout: Error creating trigger: {
   2017-08-15T09:50:34.511548026Z stdout: "name": "StatusCodeError",
   2017-08-15T09:50:34.511552003Z stdout: "statusCode": 500,
   2017-08-15T09:50:34.511554501Z stdout: "message": "500 - \"Error: error 
happened in your connection\"",
   2017-08-15T09:50:34.511557142Z stdout: "error": "Error: error happened in 
your connection",
   2017-08-15T09:50:34.511559611Z stdout: "options": {
   2017-08-15T09:50:34.511561707Z stdout: "method": "PUT",
   2017-08-15T09:50:34.511564397Z stdout: "url": 
"https://172.17.0.1/api/v1/web/whisk.system/messagingWeb/kafkaFeedWeb.http;,
   2017-08-15T09:50:34.511570175Z stdout: "rejectUnauthorized": false,
   2017-08-15T09:50:34.511572303Z stdout: "json": true,
   2017-08-15T09:50:34.511574498Z stdout: "body": {
   2017-08-15T09:50:34.51157697Z  stdout: "authKey": 
"789c46b1-71f6-4ed5-8c54-816aa4f8c502:abczO3xZCLrMN6v2BKK1dXYFpXlPkccOFqm12CdAsMgRU4VrNZ9lyGVCGuMDGIwP",
   2017-08-15T09:50:34.51158097Z  stdout: "isJSONData": true,
   2017-08-15T09:50:34.511584471Z stdout: "brokers": "mykafkahost:9092, 
mykafkahost:9093",
   2017-08-15T09:50:34.511588192Z stdout: "topic": "mytopic",
   2017-08-15T09:50:34.511591885Z stdout: "triggerName": 
"/whisk.system/MyKafkaTrigger"
   2017-08-15T09:50:34.511595503Z stdout: },
   2017-08-15T09:50:34.511598525Z stdout: "headers": {
   2017-08-15T09:50:34.511602038Z stdout: "Content-Type": "application/json",
   2017-08-15T09:50:34.511605702Z stdout: "Accept": "text/plain",
   2017-08-15T09:50:34.511609225Z stdout: "User-Agent": "whisk"
   2017-08-15T09:50:34.511612934Z stdout: },
   2017-08-15T09:50:34.511618017Z stdout: "simple": true,
   2017-08-15T09:50:34.511621631Z stdout: "resolveWithFullResponse": false,
   2017-08-15T09:50:34.511625174Z stdout: "transform2xxOnly": false
   2017-08-15T09:50:34.511628593Z stdout: },
   2017-08-15T09:50:34.511631863Z stdout: "response": {
   2017-08-15T09:50:34.511635333Z stdout: "statusCode": 500,
   2017-08-15T09:50:34.511639172Z stdout: "body": "Error: error happened in 
your connection",
   2017-08-15T09:50:34.511643199Z stdout: "headers": {
   2017-08-15T09:50:34.511646877Z stdout: "server": "nginx/1.11.13",
   2017-08-15T09:50:34.511650606Z stdout: "date": "Tue, 15 Aug 2017 09:50:34 
GMT",
   2017-08-15T09:50:34.511654232Z stdout: "content-type": "text/plain",
   2017-08-15T09:50:34.511657958Z stdout: "content-length": "40",
   2017-08-15T09:50:34.511665314Z stdout: "connection": "close",

[GitHub] zhy989 commented on issue #210: How to use message feed

2017-08-15 Thread git

zhy989 commented on issue #210: How to use message feed
URL: 
https://github.com/apache/incubator-openwhisk-package-kafka/issues/210#issuecomment-322427182
 
 
   @bjustin-ibm thanks!
   I had run the docker image(kafkafeedprovider) successfully.
   
   then I try to create kafka trigger with CLI :
   - wsk trigger create MyKafkaTrigger -f /whisk.system/messaging/kafkaFeed -p 
brokers "mykafkahost:9092, mykafkahost:9093" -p topic mytopic -p isJSONData 
true -i
   ok: invoked /whisk.system/messaging/kafkaFeed with id 
5c4ec13b87ca48698dbee7dbc7b10e0b
   {
   "activationId": "5c4ec13b87ca48698dbee7dbc7b10e0b",
   "annotations": [
   {
   "key": "limits",
   "value": {
   "logs": 10,
   "memory": 256,
   "timeout": 6
   }
   },
   {
   "key": "path",
   "value": "whisk.system/messaging/kafkaFeed"
   }
   ],
   "duration": 1496,
   "end": 1502790634515,
   "logs": [],
   "name": "kafkaFeed",
   "namespace": "whisk.system",
   "publish": false,
   "response": {
   "result": {
   "error": "Error: error happened in your connection"
   },
   "status": "application error",
   "success": false
   },
   "start": 1502790633019,
   "subject": "whisk.system",
   "version": "0.0.3"
   }
   ok: invoked /whisk.system/messaging/kafkaFeed with id 
111b55bf70e248ba90beca624d0ed123
   {
   "activationId": "111b55bf70e248ba90beca624d0ed123",
   "annotations": [
   {
   "key": "limits",
   "value": {
   "logs": 10,
   "memory": 256,
   "timeout": 6
   }
   },
   {
   "key": "path",
   "value": "whisk.system/messaging/kafkaFeed"
   }
   ],
   "duration": 501,
   "end": 1502790635383,
   "logs": [],
   "name": "kafkaFeed",
   "namespace": "whisk.system",
   "publish": false,
   "response": {
   "result": {},
   "status": "success",
   "success": true
   },
   "start": 1502790634882,
   "subject": "whisk.system",
   "version": "0.0.3"
   }
   ok: deleted trigger MyKafkaTrigger
   Run 'wsk --help' for usage.
   
   It failed , the logs is as below:
   
   - wsk -i activation logs 5c4ec13b87ca48698dbee7dbc7b10e0b
   2017-08-15T09:50:34.511516922Z stdout: Error creating trigger: {
   2017-08-15T09:50:34.511548026Z stdout: "name": "StatusCodeError",
   2017-08-15T09:50:34.511552003Z stdout: "statusCode": 500,
   2017-08-15T09:50:34.511554501Z stdout: "message": "500 - \"Error: error 
happened in your connection\"",
   2017-08-15T09:50:34.511557142Z stdout: "error": "Error: error happened in 
your connection",
   2017-08-15T09:50:34.511559611Z stdout: "options": {
   2017-08-15T09:50:34.511561707Z stdout: "method": "PUT",
   2017-08-15T09:50:34.511564397Z stdout: "url": 
"https://172.17.0.1/api/v1/web/whisk.system/messagingWeb/kafkaFeedWeb.http;,
   2017-08-15T09:50:34.511570175Z stdout: "rejectUnauthorized": false,
   2017-08-15T09:50:34.511572303Z stdout: "json": true,
   2017-08-15T09:50:34.511574498Z stdout: "body": {
   2017-08-15T09:50:34.51157697Z  stdout: "authKey": 
"789c46b1-71f6-4ed5-8c54-816aa4f8c502:abczO3xZCLrMN6v2BKK1dXYFpXlPkccOFqm12CdAsMgRU4VrNZ9lyGVCGuMDGIwP",
   2017-08-15T09:50:34.51158097Z  stdout: "isJSONData": true,
   2017-08-15T09:50:34.511584471Z stdout: "brokers": "mykafkahost:9092, 
mykafkahost:9093",
   2017-08-15T09:50:34.511588192Z stdout: "topic": "mytopic",
   2017-08-15T09:50:34.511591885Z stdout: "triggerName": 
"/whisk.system/MyKafkaTrigger"
   2017-08-15T09:50:34.511595503Z stdout: },
   2017-08-15T09:50:34.511598525Z stdout: "headers": {
   2017-08-15T09:50:34.511602038Z stdout: "Content-Type": "application/json",
   2017-08-15T09:50:34.511605702Z stdout: "Accept": "text/plain",
   2017-08-15T09:50:34.511609225Z stdout: "User-Agent": "whisk"
   2017-08-15T09:50:34.511612934Z stdout: },
   2017-08-15T09:50:34.511618017Z stdout: "simple": true,
   2017-08-15T09:50:34.511621631Z stdout: "resolveWithFullResponse": false,
   2017-08-15T09:50:34.511625174Z stdout: "transform2xxOnly": false
   2017-08-15T09:50:34.511628593Z stdout: },
   2017-08-15T09:50:34.511631863Z stdout: "response": {
   2017-08-15T09:50:34.511635333Z stdout: "statusCode": 500,
   2017-08-15T09:50:34.511639172Z stdout: "body": "Error: error happened in 
your connection",
   2017-08-15T09:50:34.511643199Z stdout: "headers": {
   2017-08-15T09:50:34.511646877Z stdout: "server": "nginx/1.11.13",
   2017-08-15T09:50:34.511650606Z stdout: "date": "Tue, 15 Aug 2017 09:50:34 
GMT",
   2017-08-15T09:50:34.511654232Z stdout: "content-type": "text/plain",
   2017-08-15T09:50:34.511657958Z stdout: "content-length": "40",
   2017-08-15T09:50:34.511665314Z stdout: "connection": "close",

[GitHub] zhy989 commented on issue #210: How to use message feed

2017-08-14 Thread git

zhy989 commented on issue #210: How to use message feed
URL: 
https://github.com/apache/incubator-openwhisk-package-kafka/issues/210#issuecomment-322152650
 
 
   @bjustin-ibm thanks
   
   I had run Kafka instance successfully follow 
"https://kafka.apache.org/quickstart;.
   
   I re download the code from 
"https://github.com/bjustin-ibm/openwhisk-package-kafka; and update to 
   the master branch .
   
   run the docker image and  got the same error as before:
   
   - Traceback (most recent call last):
 File "app.py", line 24, in 
   from consumer import Consumer
 File "/KafkaFeedProvider/consumer.py", line 24, in 
   from database import Database
 File "/KafkaFeedProvider/database.py", line 23, in 
   class Database:
 File "/KafkaFeedProvider/database.py", line 26, in Database
   username = os.environ['CLOUDANT_USER']
 File "/usr/lib/python2.7/UserDict.py", line 40, in __getitem__
   raise KeyError(key)
   KeyError: 'CLOUDANT_USER'
   
   I download code from 
"https://github.com/apache/incubator-openwhisk-package-kafka;
   run the docker image and got the error as below  
   
   - Traceback (most recent call last):
 File "app.py", line 97, in 
   main()
 File "app.py", line 83, in main
   database = Database()
 File "/KafkaFeedProvider/database.py", line 46, in __init__
   client.connect()
 File "/usr/local/lib/python2.7/dist-packages/cloudant/client.py", line 
114, in connect
   self.session_login(self._user, self._auth_token)
 File "/usr/local/lib/python2.7/dist-packages/cloudant/client.py", line 
170, in session_login
   headers={'Content-Type': 'application/x-www-form-urlencoded'}
 File "/usr/local/lib/python2.7/dist-packages/requests/sessions.py", line 
518, in post
   return self.request('POST', url, data=data, json=json, **kwargs)
 File "/usr/local/lib/python2.7/dist-packages/cloudant/_common_util.py", 
line 346, in request
   method, url, timeout=self._timeout, **kwargs)
 File "/usr/local/lib/python2.7/dist-packages/requests/sessions.py", line 
475, in request
   resp = self.send(prep, **send_kwargs)
 File "/usr/local/lib/python2.7/dist-packages/requests/sessions.py", line 
585, in send
   r = adapter.send(request, **kwargs)
 File "/usr/local/lib/python2.7/dist-packages/requests/adapters.py", line 
477, in send
   raise SSLError(e, request=request)
   requests.exceptions.SSLError: [SSL: UNKNOWN_PROTOCOL] unknown protocol 
(_ssl.c:590)
   
 

This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


With regards,
Apache Git Services

[GitHub] zhy989 commented on issue #210: How to use message feed

2017-08-10 Thread git

zhy989 commented on issue #210: How to use message feed
URL: 
https://github.com/apache/incubator-openwhisk-package-kafka/issues/210#issuecomment-321536519
 
 
   @bjustin-ibm thanks
   in case 1 
   
   - Setting up a Message Hub package outside Bluemix
   Is this install Message Hub package on the local host outside Bluemix?
   
   I can sign in Bluemix with my username and password, why can not 
authenticate with Message Hub with the same username and password when I run 
the CLI "wsk -i trigger create MyMessageHubTrigger -f 
myMessageHub/messageHubFeed -p topic mytopic -p isJSONData true -p"?
   
   
   in case 2
   I try to run the example for 
"https://github.com/bjustin-ibm/openwhisk-package-kafka/blob/1aa6ae1684930d5175fa0ce36886b2e7db123248/devGuide.md;
   
   I can create docker image  kafkafeedprovider successfully
   but when I run script docker_run.sh, there is an error:
   - cat docker_run.sh 
   WSK_HOME=/openwhisk
   DB_PROTOCOL=`awk -F "=" '/db_protocol/ {print $2}' 
$WSK_HOME/ansible/db_local.ini`
   DB_HOST=`awk -F "=" '/db_host/ {print $2}' $WSK_HOME/ansible/db_local.ini`
   DB_PORT=`awk -F "=" '/db_port/ {print $2}' $WSK_HOME/ansible/db_local.ini`
   DB_USER=`awk -F "=" '/db_username/ {print $2}' 
$WSK_HOME/ansible/db_local.ini`
   DB_PWD=`awk -F "=" '/db_password/ {print $2}' $WSK_HOME/ansible/db_local.ini`
   DB_PREFIX=test
   docker run -e DB_URL="https://172.17.0.1:5984; -e DB_USER=$DB_USER -e 
DB_PASS=$DB_PWD -p 81:5000 kafkafeedprovider
   
   - Traceback (most recent call last):
 File "app.py", line 24, in 
   from consumer import Consumer
 File "/KafkaFeedProvider/consumer.py", line 24, in 
   from database import Database
 File "/KafkaFeedProvider/database.py", line 23, in 
   class Database:
 File "/KafkaFeedProvider/database.py", line 26, in Database
   username = os.environ['CLOUDANT_USER']
 File "/usr/lib/python2.7/UserDict.py", line 40, in __getitem__
   raise KeyError(key)
   KeyError: 'CLOUDANT_USER'
   
   In here it must be CLOUDANT_USER ?  couchdb_user can not ?
   
 

This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


With regards,
Apache Git Services

[GitHub] zhy989 commented on issue #210: How to use message feed

2017-08-10 Thread git

zhy989 commented on issue #210: How to use message feed
URL: 
https://github.com/apache/incubator-openwhisk-package-kafka/issues/210#issuecomment-321536519
 
 
   @bjustin-ibm thanks
   in case 1 
   
   - Setting up a Message Hub package outside Bluemix
   Is this install Message Hub package on the local host outside Bluemix?
   
   I can sign in Bluemix with my username and password, why can not 
authenticate with Message Hub with the same username and password when I run 
the CLI "wsk -i trigger create MyMessageHubTrigger -f 
myMessageHub/messageHubFeed -p topic mytopic -p isJSONData true -p"?
   
 

This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


With regards,
Apache Git Services

[GitHub] zhy989 commented on issue #210: How to use message feed

2017-08-10 Thread git

zhy989 commented on issue #210: How to use message feed
URL: 
https://github.com/apache/incubator-openwhisk-package-kafka/issues/210#issuecomment-321508475
 
 
   @bjustin-ibm thanks
   in case 1:
   Should I register a new account on the local host for message hub?
   in case 2:
   I tried  this CLI "wsk trigger create MyKafkaTrigger -f 
/whisk.system/messaging/kafkaFeed -p brokers 
"mykafkahost:9092,mykafkahost:9093" -p topic mytopic -p isJSONData true -i", 
and got the same error
   
   - wsk trigger create MyKafkaTrigger -f /whisk.system/messaging/kafkaFeed -p 
brokers "mykafkahost:9092,mykafkahost:9093" -p topic mytopic -p isJSONData true 
-i
   ok: invoked /whisk.system/messaging/kafkaFeed with id 
fff3cab0fde142e98ac81ba3a98db38c
   {
   "activationId": "fff3cab0fde142e98ac81ba3a98db38c",
   "annotations": [
   {
   "key": "limits",
   "value": {
   "logs": 10,
   "memory": 256,
   "timeout": 6
   }
   },
   {
   "key": "path",
   "value": "whisk.system/messaging/kafkaFeed"
   }
   ],
   "duration": 991,
   "end": 1502359181855,
   "logs": [],
   "name": "kafkaFeed",
   "namespace": "whisk.system",
   "publish": false,
   "response": {
   "result": {
   "error": "Error: error happened in your connection"
   },
   "status": "application error",
   "success": false
   },
   "start": 1502359180864,
   "subject": "whisk.system",
   "version": "0.0.2"
   }
   ok: invoked /whisk.system/messaging/kafkaFeed with id 
c0cb00c7f1964151a2aabd5f35ef8d4f
   {
   "activationId": "c0cb00c7f1964151a2aabd5f35ef8d4f",
   "annotations": [
   {
   "key": "limits",
   "value": {
   "logs": 10,
   "memory": 256,
   "timeout": 6
   }
   },
   {
   "key": "path",
   "value": "whisk.system/messaging/kafkaFeed"
   }
   ],
   "duration": 501,
   "end": 1502359182811,
   "logs": [],
   "name": "kafkaFeed",
   "namespace": "whisk.system",
   "publish": false,
   "response": {
   "result": {},
   "status": "success",
   "success": true
   },
   "start": 1502359182310,
   "subject": "whisk.system",
   "version": "0.0.2"
   }
   ok: deleted trigger MyKafkaTrigger
   
   - wsk -i activation logs fff3cab0fde142e98ac81ba3a98db38c
   2017-08-10T09:59:41.851044685Z stdout: Error creating trigger: {
   2017-08-10T09:59:41.851069919Z stdout: "name": "StatusCodeError",
   2017-08-10T09:59:41.851073662Z stdout: "statusCode": 500,
   2017-08-10T09:59:41.851076502Z stdout: "message": "500 - \"Error: error 
happened in your connection\"",
   2017-08-10T09:59:41.851081688Z stdout: "error": "Error: error happened in 
your connection",
   2017-08-10T09:59:41.851084534Z stdout: "options": {
   2017-08-10T09:59:41.851087266Z stdout: "method": "PUT",
   2017-08-10T09:59:41.851090286Z stdout: "url": 
"https://172.17.0.1/api/v1/web/whisk.system/messagingWeb/kafkaFeedWeb.http;,
   2017-08-10T09:59:41.85109325Z  stdout: "rejectUnauthorized": false,
   2017-08-10T09:59:41.851095837Z stdout: "json": true,
   2017-08-10T09:59:41.851098218Z stdout: "body": {
   2017-08-10T09:59:41.851100973Z stdout: "authKey": 
"789c46b1-71f6-4ed5-8c54-816aa4f8c502:abczO3xZCLrMN6v2BKK1dXYFpXlPkccOFqm12CdAsMgRU4VrNZ9lyGVCGuMDGIwP",
   2017-08-10T09:59:41.851103755Z stdout: "isJSONData": true,
   2017-08-10T09:59:41.851107298Z stdout: "brokers": 
"mykafkahost:9092,mykafkahost:9093",
   2017-08-10T09:59:41.851109876Z stdout: "topic": "mytopic",
   2017-08-10T09:59:41.851112397Z stdout: "triggerName": 
"/whisk.system/MyKafkaTrigger"
   2017-08-10T09:59:41.851115008Z stdout: },
   2017-08-10T09:59:41.851117353Z stdout: "headers": {
   2017-08-10T09:59:41.851119788Z stdout: "Content-Type": "application/json",
   2017-08-10T09:59:41.851122322Z stdout: "Accept": "text/plain",
   2017-08-10T09:59:41.851150998Z stdout: "User-Agent": "whisk"
   2017-08-10T09:59:41.851155301Z stdout: },
   2017-08-10T09:59:41.851157521Z stdout: "simple": true,
   2017-08-10T09:59:41.851160009Z stdout: "resolveWithFullResponse": false,
   2017-08-10T09:59:41.851162485Z stdout: "transform2xxOnly": false
   2017-08-10T09:59:41.851164913Z stdout: },
   2017-08-10T09:59:41.851167255Z stdout: "response": {
   2017-08-10T09:59:41.851170448Z stdout: "statusCode": 500,
   2017-08-10T09:59:41.851172917Z stdout: "body": "Error: error happened in 
your connection",
   2017-08-10T09:59:41.85117544Z  stdout: "headers": {
   2017-08-10T09:59:41.851177892Z stdout: "server": "nginx/1.11.13",
   2017-08-10T09:59:41.851180284Z stdout: "date": "Thu, 10 Aug 2017 09:59:41 
GMT",
   2017-08-10T09:59:41.851182731Z stdout: "content-type": "text/plain",

[GitHub] zhy989 commented on issue #210: How to use message feed

2017-08-10 Thread git

zhy989 commented on issue #210: How to use message feed
URL: 
https://github.com/apache/incubator-openwhisk-package-kafka/issues/210#issuecomment-321508475
 
 
   @bjustin-ibm thanks
   in case 1:
   Should I register a new accoun on the local host for message hub?
   in case 2:
   I tried  this CLI "wsk trigger create MyKafkaTrigger -f 
/whisk.system/messaging/kafkaFeed -p brokers 
"mykafkahost:9092,mykafkahost:9093" -p topic mytopic -p isJSONData true -i", 
and got the same error
   
   - wsk trigger create MyKafkaTrigger -f /whisk.system/messaging/kafkaFeed -p 
brokers "mykafkahost:9092,mykafkahost:9093" -p topic mytopic -p isJSONData true 
-i
   ok: invoked /whisk.system/messaging/kafkaFeed with id 
fff3cab0fde142e98ac81ba3a98db38c
   {
   "activationId": "fff3cab0fde142e98ac81ba3a98db38c",
   "annotations": [
   {
   "key": "limits",
   "value": {
   "logs": 10,
   "memory": 256,
   "timeout": 6
   }
   },
   {
   "key": "path",
   "value": "whisk.system/messaging/kafkaFeed"
   }
   ],
   "duration": 991,
   "end": 1502359181855,
   "logs": [],
   "name": "kafkaFeed",
   "namespace": "whisk.system",
   "publish": false,
   "response": {
   "result": {
   "error": "Error: error happened in your connection"
   },
   "status": "application error",
   "success": false
   },
   "start": 1502359180864,
   "subject": "whisk.system",
   "version": "0.0.2"
   }
   ok: invoked /whisk.system/messaging/kafkaFeed with id 
c0cb00c7f1964151a2aabd5f35ef8d4f
   {
   "activationId": "c0cb00c7f1964151a2aabd5f35ef8d4f",
   "annotations": [
   {
   "key": "limits",
   "value": {
   "logs": 10,
   "memory": 256,
   "timeout": 6
   }
   },
   {
   "key": "path",
   "value": "whisk.system/messaging/kafkaFeed"
   }
   ],
   "duration": 501,
   "end": 1502359182811,
   "logs": [],
   "name": "kafkaFeed",
   "namespace": "whisk.system",
   "publish": false,
   "response": {
   "result": {},
   "status": "success",
   "success": true
   },
   "start": 1502359182310,
   "subject": "whisk.system",
   "version": "0.0.2"
   }
   ok: deleted trigger MyKafkaTrigger
   
   - wsk -i activation logs fff3cab0fde142e98ac81ba3a98db38c
   2017-08-10T09:59:41.851044685Z stdout: Error creating trigger: {
   2017-08-10T09:59:41.851069919Z stdout: "name": "StatusCodeError",
   2017-08-10T09:59:41.851073662Z stdout: "statusCode": 500,
   2017-08-10T09:59:41.851076502Z stdout: "message": "500 - \"Error: error 
happened in your connection\"",
   2017-08-10T09:59:41.851081688Z stdout: "error": "Error: error happened in 
your connection",
   2017-08-10T09:59:41.851084534Z stdout: "options": {
   2017-08-10T09:59:41.851087266Z stdout: "method": "PUT",
   2017-08-10T09:59:41.851090286Z stdout: "url": 
"https://172.17.0.1/api/v1/web/whisk.system/messagingWeb/kafkaFeedWeb.http;,
   2017-08-10T09:59:41.85109325Z  stdout: "rejectUnauthorized": false,
   2017-08-10T09:59:41.851095837Z stdout: "json": true,
   2017-08-10T09:59:41.851098218Z stdout: "body": {
   2017-08-10T09:59:41.851100973Z stdout: "authKey": 
"789c46b1-71f6-4ed5-8c54-816aa4f8c502:abczO3xZCLrMN6v2BKK1dXYFpXlPkccOFqm12CdAsMgRU4VrNZ9lyGVCGuMDGIwP",
   2017-08-10T09:59:41.851103755Z stdout: "isJSONData": true,
   2017-08-10T09:59:41.851107298Z stdout: "brokers": 
"mykafkahost:9092,mykafkahost:9093",
   2017-08-10T09:59:41.851109876Z stdout: "topic": "mytopic",
   2017-08-10T09:59:41.851112397Z stdout: "triggerName": 
"/whisk.system/MyKafkaTrigger"
   2017-08-10T09:59:41.851115008Z stdout: },
   2017-08-10T09:59:41.851117353Z stdout: "headers": {
   2017-08-10T09:59:41.851119788Z stdout: "Content-Type": "application/json",
   2017-08-10T09:59:41.851122322Z stdout: "Accept": "text/plain",
   2017-08-10T09:59:41.851150998Z stdout: "User-Agent": "whisk"
   2017-08-10T09:59:41.851155301Z stdout: },
   2017-08-10T09:59:41.851157521Z stdout: "simple": true,
   2017-08-10T09:59:41.851160009Z stdout: "resolveWithFullResponse": false,
   2017-08-10T09:59:41.851162485Z stdout: "transform2xxOnly": false
   2017-08-10T09:59:41.851164913Z stdout: },
   2017-08-10T09:59:41.851167255Z stdout: "response": {
   2017-08-10T09:59:41.851170448Z stdout: "statusCode": 500,
   2017-08-10T09:59:41.851172917Z stdout: "body": "Error: error happened in 
your connection",
   2017-08-10T09:59:41.85117544Z  stdout: "headers": {
   2017-08-10T09:59:41.851177892Z stdout: "server": "nginx/1.11.13",
   2017-08-10T09:59:41.851180284Z stdout: "date": "Thu, 10 Aug 2017 09:59:41 
GMT",
   2017-08-10T09:59:41.851182731Z stdout: "content-type": "text/plain",

[GitHub] zhy989 commented on issue #210: How to use message feed

2017-08-09 Thread git

zhy989 commented on issue #210: How to use message feed
URL: 
https://github.com/apache/incubator-openwhisk-package-kafka/issues/210#issuecomment-321186024
 
 
   @bjustin-ibm  thanks !  I update the ip address from localhost to 
172.17.0.1, but there is another failure about  "Could not authenticate with 
Message Hub. Please check your credentials" with messageHub  and "connection 
error" with  kafkaMessage
   
   - wsk trigger create MyMessageHubTrigger -f myMessageHub/messageHubFeed -p 
topic mytopic -p isJSONData true -i 
   
   The log is as below:
   
   - wsk -i activation logs dfa140ac32d94b458bdb52056658fbc7
   2017-08-09T08:14:21.619050308Z stdout: Error creating trigger: {
   2017-08-09T08:14:21.619087376Z stdout: "name": "StatusCodeError",
   2017-08-09T08:14:21.619091409Z stdout: "statusCode": 500,
   2017-08-09T08:14:21.61909419Z  stdout: "message": "500 - \"Could not 
authenticate with Message Hub. Please check your credentials.\"",
   2017-08-09T08:14:21.619098159Z stdout: "error": "Could not authenticate with 
Message Hub. Please check your credentials.",
   2017-08-09T08:14:21.619100844Z stdout: "options": {
   2017-08-09T08:14:21.619103049Z stdout: "method": "PUT",
   2017-08-09T08:14:21.619105524Z stdout: "url": 
"https://172.17.0.1/api/v1/web/whisk.system/messagingWeb/messageHubFeedWeb.http;,
   2017-08-09T08:14:21.619107919Z stdout: "rejectUnauthorized": false,
   2017-08-09T08:14:21.61911018Z  stdout: "json": true,
   2017-08-09T08:14:21.619112377Z stdout: "body": {
   2017-08-09T08:14:21.619114898Z stdout: "authKey": 
"789c46b1-71f6-4ed5-8c54-816aa4f8c502:abczO3xZCLrMN6v2BKK1dXYFpXlPkccOFqm12CdAsMgRU4VrNZ9lyGVCGuMDGIwP",
   2017-08-09T08:14:21.619117412Z stdout: "kafka_brokers_sasl": [
   2017-08-09T08:14:21.619119613Z stdout: 
"kafka01-prod01.messagehub.services.us-south.bluemix.net:9093",
   2017-08-09T08:14:21.619121844Z stdout: 
"kafka02-prod01.messagehub.services.us-south.bluemix.net:9093",
   2017-08-09T08:14:21.619133953Z stdout: 
"kafka03-prod01.messagehub.services.us-south.bluemix.net:9093"
   2017-08-09T08:14:21.619137142Z stdout: ],
   2017-08-09T08:14:21.619139602Z stdout: "isJSONData": true,
   2017-08-09T08:14:21.619141929Z stdout: "kafka_admin_url": 
"https://kafka-admin-prod01.messagehub.services.us-south.bluemix.net:443;,
   2017-08-09T08:14:21.619144551Z stdout: "topic": "mytopic",
   2017-08-09T08:14:21.619146802Z stdout: "user": "***",
   2017-08-09T08:14:21.619149821Z stdout: "triggerName": 
"/whisk.system/MyMessageHubTrigger",
   2017-08-09T08:14:21.619152212Z stdout: "password": "***"
   2017-08-09T08:14:21.619154572Z stdout: },
   2017-08-09T08:14:21.619156595Z stdout: "headers": {
   2017-08-09T08:14:21.619158762Z stdout: "Content-Type": "application/json",
   2017-08-09T08:14:21.619160909Z stdout: "Accept": "text/plain",
   2017-08-09T08:14:21.619163024Z stdout: "User-Agent": "whisk"
   2017-08-09T08:14:21.619165407Z stdout: },
   2017-08-09T08:14:21.619168625Z stdout: "simple": true,
   2017-08-09T08:14:21.61917201Z  stdout: "resolveWithFullResponse": false,
   2017-08-09T08:14:21.619175706Z stdout: "transform2xxOnly": false
   2017-08-09T08:14:21.619179148Z stdout: },
   2017-08-09T08:14:21.619182378Z stdout: "response": {
   2017-08-09T08:14:21.619185724Z stdout: "statusCode": 500,
   2017-08-09T08:14:21.619189488Z stdout: "body": "Could not authenticate with 
Message Hub. Please check your credentials.",
   2017-08-09T08:14:21.619193472Z stdout: "headers": {
   2017-08-09T08:14:21.619203766Z stdout: "server": "nginx/1.11.13",
   2017-08-09T08:14:21.619208512Z stdout: "date": "Wed, 09 Aug 2017 08:14:21 
GMT",
   2017-08-09T08:14:21.619212396Z stdout: "content-type": "text/plain",
   2017-08-09T08:14:21.619231211Z stdout: "content-length": "71",
   2017-08-09T08:14:21.619234996Z stdout: "connection": "close",
   2017-08-09T08:14:21.619238744Z stdout: "access-control-allow-origin": "*",
   2017-08-09T08:14:21.619243008Z stdout: "access-control-allow-methods": 
"OPTIONS, GET, DELETE, POST, PUT, HEAD, PATCH",
   2017-08-09T08:14:21.619247074Z stdout: "access-control-allow-headers": 
"Authorization, Content-Type"
   2017-08-09T08:14:21.619250843Z stdout: },
   2017-08-09T08:14:21.619254203Z stdout: "request": {
   2017-08-09T08:14:21.619257728Z stdout: "uri": {
   2017-08-09T08:14:21.619261254Z stdout: "protocol": "https:",
   2017-08-09T08:14:21.619264957Z stdout: "slashes": true,
   2017-08-09T08:14:21.61926851Z  stdout: "auth": null,
   2017-08-09T08:14:21.619272071Z stdout: "host": "172.17.0.1",
   2017-08-09T08:14:21.619275757Z stdout: "port": 443,
   2017-08-09T08:14:21.619279277Z stdout: "hostname": "172.17.0.1",
   2017-08-09T08:14:21.619282954Z stdout: "hash": null,
   2017-08-09T08:14:21.619292772Z stdout: "search": null,
   2017-08-09T08:14:21.619296406Z stdout: "query": null,
   2017-08-09T08:14:21.619299978Z stdout: "pathname": 
"/api/v1/web/whisk.system/messagingWeb/messageHubFeedWeb.http",
   2017-08-09T08:14:21.619303997Z stdout: "path":

[GitHub] zhy989 commented on issue #210: How to use message feed

2017-08-09 Thread git

zhy989 commented on issue #210: How to use message feed
URL: 
https://github.com/apache/incubator-openwhisk-package-kafka/issues/210#issuecomment-321186024
 
 
   @bjustin-ibm  thanks !  I update the ip address from localhost to 
172.17.0.1, but there is another failure about  "Could not authenticate with 
Message Hub. Please check your credentials".
   
   The log is as below:
   
   - wsk -i activation logs dfa140ac32d94b458bdb52056658fbc7
   2017-08-09T08:14:21.619050308Z stdout: Error creating trigger: {
   2017-08-09T08:14:21.619087376Z stdout: "name": "StatusCodeError",
   2017-08-09T08:14:21.619091409Z stdout: "statusCode": 500,
   2017-08-09T08:14:21.61909419Z  stdout: "message": "500 - \"Could not 
authenticate with Message Hub. Please check your credentials.\"",
   2017-08-09T08:14:21.619098159Z stdout: "error": "Could not authenticate with 
Message Hub. Please check your credentials.",
   2017-08-09T08:14:21.619100844Z stdout: "options": {
   2017-08-09T08:14:21.619103049Z stdout: "method": "PUT",
   2017-08-09T08:14:21.619105524Z stdout: "url": 
"https://172.17.0.1/api/v1/web/whisk.system/messagingWeb/messageHubFeedWeb.http;,
   2017-08-09T08:14:21.619107919Z stdout: "rejectUnauthorized": false,
   2017-08-09T08:14:21.61911018Z  stdout: "json": true,
   2017-08-09T08:14:21.619112377Z stdout: "body": {
   2017-08-09T08:14:21.619114898Z stdout: "authKey": 
"789c46b1-71f6-4ed5-8c54-816aa4f8c502:abczO3xZCLrMN6v2BKK1dXYFpXlPkccOFqm12CdAsMgRU4VrNZ9lyGVCGuMDGIwP",
   2017-08-09T08:14:21.619117412Z stdout: "kafka_brokers_sasl": [
   2017-08-09T08:14:21.619119613Z stdout: 
"kafka01-prod01.messagehub.services.us-south.bluemix.net:9093",
   2017-08-09T08:14:21.619121844Z stdout: 
"kafka02-prod01.messagehub.services.us-south.bluemix.net:9093",
   2017-08-09T08:14:21.619133953Z stdout: 
"kafka03-prod01.messagehub.services.us-south.bluemix.net:9093"
   2017-08-09T08:14:21.619137142Z stdout: ],
   2017-08-09T08:14:21.619139602Z stdout: "isJSONData": true,
   2017-08-09T08:14:21.619141929Z stdout: "kafka_admin_url": 
"https://kafka-admin-prod01.messagehub.services.us-south.bluemix.net:443;,
   2017-08-09T08:14:21.619144551Z stdout: "topic": "mytopic",
   2017-08-09T08:14:21.619146802Z stdout: "user": "***",
   2017-08-09T08:14:21.619149821Z stdout: "triggerName": 
"/whisk.system/MyMessageHubTrigger",
   2017-08-09T08:14:21.619152212Z stdout: "password": "***"
   2017-08-09T08:14:21.619154572Z stdout: },
   2017-08-09T08:14:21.619156595Z stdout: "headers": {
   2017-08-09T08:14:21.619158762Z stdout: "Content-Type": "application/json",
   2017-08-09T08:14:21.619160909Z stdout: "Accept": "text/plain",
   2017-08-09T08:14:21.619163024Z stdout: "User-Agent": "whisk"
   2017-08-09T08:14:21.619165407Z stdout: },
   2017-08-09T08:14:21.619168625Z stdout: "simple": true,
   2017-08-09T08:14:21.61917201Z  stdout: "resolveWithFullResponse": false,
   2017-08-09T08:14:21.619175706Z stdout: "transform2xxOnly": false
   2017-08-09T08:14:21.619179148Z stdout: },
   2017-08-09T08:14:21.619182378Z stdout: "response": {
   2017-08-09T08:14:21.619185724Z stdout: "statusCode": 500,
   2017-08-09T08:14:21.619189488Z stdout: "body": "Could not authenticate with 
Message Hub. Please check your credentials.",
   2017-08-09T08:14:21.619193472Z stdout: "headers": {
   2017-08-09T08:14:21.619203766Z stdout: "server": "nginx/1.11.13",
   2017-08-09T08:14:21.619208512Z stdout: "date": "Wed, 09 Aug 2017 08:14:21 
GMT",
   2017-08-09T08:14:21.619212396Z stdout: "content-type": "text/plain",
   2017-08-09T08:14:21.619231211Z stdout: "content-length": "71",
   2017-08-09T08:14:21.619234996Z stdout: "connection": "close",
   2017-08-09T08:14:21.619238744Z stdout: "access-control-allow-origin": "*",
   2017-08-09T08:14:21.619243008Z stdout: "access-control-allow-methods": 
"OPTIONS, GET, DELETE, POST, PUT, HEAD, PATCH",
   2017-08-09T08:14:21.619247074Z stdout: "access-control-allow-headers": 
"Authorization, Content-Type"
   2017-08-09T08:14:21.619250843Z stdout: },
   2017-08-09T08:14:21.619254203Z stdout: "request": {
   2017-08-09T08:14:21.619257728Z stdout: "uri": {
   2017-08-09T08:14:21.619261254Z stdout: "protocol": "https:",
   2017-08-09T08:14:21.619264957Z stdout: "slashes": true,
   2017-08-09T08:14:21.61926851Z  stdout: "auth": null,
   2017-08-09T08:14:21.619272071Z stdout: "host": "172.17.0.1",
   2017-08-09T08:14:21.619275757Z stdout: "port": 443,
   2017-08-09T08:14:21.619279277Z stdout: "hostname": "172.17.0.1",
   2017-08-09T08:14:21.619282954Z stdout: "hash": null,
   2017-08-09T08:14:21.619292772Z stdout: "search": null,
   2017-08-09T08:14:21.619296406Z stdout: "query": null,
   2017-08-09T08:14:21.619299978Z stdout: "pathname": 
"/api/v1/web/whisk.system/messagingWeb/messageHubFeedWeb.http",
   2017-08-09T08:14:21.619303997Z stdout: "path": 
"/api/v1/web/whisk.system/messagingWeb/messageHubFeedWeb.http",
   2017-08-09T08:14:21.619308034Z stdout: "href":

[GitHub] zhy989 commented on issue #210: How to use message feed

2017-08-09 Thread git

zhy989 commented on issue #210: How to use message feed
URL: 
https://github.com/apache/incubator-openwhisk-package-kafka/issues/210#issuecomment-321186024
 
 
   
   @bjustin-ibm  thanks !  I update the ip address from localhost to 
172.17.0.1, but there is another failure about  "Could not authenticate with 
Message Hub. Please check your credentials".
   
   The log is as below:
   
   - wsk -i activation logs dfa140ac32d94b458bdb52056658fbc7
   2017-08-09T08:14:21.619050308Z stdout: Error creating trigger: {
   2017-08-09T08:14:21.619087376Z stdout: "name": "StatusCodeError",
   2017-08-09T08:14:21.619091409Z stdout: "statusCode": 500,
   2017-08-09T08:14:21.61909419Z  stdout: "message": "500 - \"Could not 
authenticate with Message Hub. Please check your credentials.\"",
   2017-08-09T08:14:21.619098159Z stdout: "error": "Could not authenticate with 
Message Hub. Please check your credentials.",
   2017-08-09T08:14:21.619100844Z stdout: "options": {
   2017-08-09T08:14:21.619103049Z stdout: "method": "PUT",
   2017-08-09T08:14:21.619105524Z stdout: "url": 
"https://172.17.0.1/api/v1/web/whisk.system/messagingWeb/messageHubFeedWeb.http;,
   2017-08-09T08:14:21.619107919Z stdout: "rejectUnauthorized": false,
   2017-08-09T08:14:21.61911018Z  stdout: "json": true,
   2017-08-09T08:14:21.619112377Z stdout: "body": {
   2017-08-09T08:14:21.619114898Z stdout: "authKey": 
"789c46b1-71f6-4ed5-8c54-816aa4f8c502:abczO3xZCLrMN6v2BKK1dXYFpXlPkccOFqm12CdAsMgRU4VrNZ9lyGVCGuMDGIwP",
   2017-08-09T08:14:21.619117412Z stdout: "kafka_brokers_sasl": [
   2017-08-09T08:14:21.619119613Z stdout: 
"kafka01-prod01.messagehub.services.us-south.bluemix.net:9093",
   2017-08-09T08:14:21.619121844Z stdout: 
"kafka02-prod01.messagehub.services.us-south.bluemix.net:9093",
   2017-08-09T08:14:21.619133953Z stdout: 
"kafka03-prod01.messagehub.services.us-south.bluemix.net:9093"
   2017-08-09T08:14:21.619137142Z stdout: ],
   2017-08-09T08:14:21.619139602Z stdout: "isJSONData": true,
   2017-08-09T08:14:21.619141929Z stdout: "kafka_admin_url": 
"https://kafka-admin-prod01.messagehub.services.us-south.bluemix.net:443;,
   2017-08-09T08:14:21.619144551Z stdout: "topic": "mytopic",
   2017-08-09T08:14:21.619146802Z stdout: "user": "653070...@qq.com",
   2017-08-09T08:14:21.619149821Z stdout: "triggerName": 
"/whisk.system/MyMessageHubTrigger",
   2017-08-09T08:14:21.619152212Z stdout: "password": "H3c123!"
   2017-08-09T08:14:21.619154572Z stdout: },
   2017-08-09T08:14:21.619156595Z stdout: "headers": {
   2017-08-09T08:14:21.619158762Z stdout: "Content-Type": "application/json",
   2017-08-09T08:14:21.619160909Z stdout: "Accept": "text/plain",
   2017-08-09T08:14:21.619163024Z stdout: "User-Agent": "whisk"
   2017-08-09T08:14:21.619165407Z stdout: },
   2017-08-09T08:14:21.619168625Z stdout: "simple": true,
   2017-08-09T08:14:21.61917201Z  stdout: "resolveWithFullResponse": false,
   2017-08-09T08:14:21.619175706Z stdout: "transform2xxOnly": false
   2017-08-09T08:14:21.619179148Z stdout: },
   2017-08-09T08:14:21.619182378Z stdout: "response": {
   2017-08-09T08:14:21.619185724Z stdout: "statusCode": 500,
   2017-08-09T08:14:21.619189488Z stdout: "body": "Could not authenticate with 
Message Hub. Please check your credentials.",
   2017-08-09T08:14:21.619193472Z stdout: "headers": {
   2017-08-09T08:14:21.619203766Z stdout: "server": "nginx/1.11.13",
   2017-08-09T08:14:21.619208512Z stdout: "date": "Wed, 09 Aug 2017 08:14:21 
GMT",
   2017-08-09T08:14:21.619212396Z stdout: "content-type": "text/plain",
   2017-08-09T08:14:21.619231211Z stdout: "content-length": "71",
   2017-08-09T08:14:21.619234996Z stdout: "connection": "close",
   2017-08-09T08:14:21.619238744Z stdout: "access-control-allow-origin": "*",
   2017-08-09T08:14:21.619243008Z stdout: "access-control-allow-methods": 
"OPTIONS, GET, DELETE, POST, PUT, HEAD, PATCH",
   2017-08-09T08:14:21.619247074Z stdout: "access-control-allow-headers": 
"Authorization, Content-Type"
   2017-08-09T08:14:21.619250843Z stdout: },
   2017-08-09T08:14:21.619254203Z stdout: "request": {
   2017-08-09T08:14:21.619257728Z stdout: "uri": {
   2017-08-09T08:14:21.619261254Z stdout: "protocol": "https:",
   2017-08-09T08:14:21.619264957Z stdout: "slashes": true,
   2017-08-09T08:14:21.61926851Z  stdout: "auth": null,
   2017-08-09T08:14:21.619272071Z stdout: "host": "172.17.0.1",
   2017-08-09T08:14:21.619275757Z stdout: "port": 443,
   2017-08-09T08:14:21.619279277Z stdout: "hostname": "172.17.0.1",
   2017-08-09T08:14:21.619282954Z stdout: "hash": null,
   2017-08-09T08:14:21.619292772Z stdout: "search": null,
   2017-08-09T08:14:21.619296406Z stdout: "query": null,
   2017-08-09T08:14:21.619299978Z stdout: "pathname": 
"/api/v1/web/whisk.system/messagingWeb/messageHubFeedWeb.http",
   2017-08-09T08:14:21.619303997Z stdout: "path": 
"/api/v1/web/whisk.system/messagingWeb/messageHubFeedWeb.http",
   2017-08-09T08:14:21.619308034Z stdout: "href":

[GitHub] zhy989 commented on issue #210: How to use message feed

2017-08-05 Thread git

zhy989 commented on issue #210: How to use message feed
URL: 
https://github.com/apache/incubator-openwhisk-package-kafka/issues/210#issuecomment-320416392
 
 
   @bjustin-ibm thanks
   - wsk -i activation logs b898ea7d32aa438a9e5bd697feaf8fe9
   2017-08-05T06:17:35.470076218Z stdout: Error creating trigger: {
   2017-08-05T06:17:35.470155869Z stdout: "name": "RequestError",
   2017-08-05T06:17:35.470163159Z stdout: "message": "Error: getaddrinfo 
ENOTFOUND https https:443",
   2017-08-05T06:17:35.470168151Z stdout: "cause": {
   2017-08-05T06:17:35.470172346Z stdout: "code": "ENOTFOUND",
   2017-08-05T06:17:35.470176705Z stdout: "errno": "ENOTFOUND",
   2017-08-05T06:17:35.470181028Z stdout: "syscall": "getaddrinfo",
   2017-08-05T06:17:35.470185235Z stdout: "hostname": "https",
   2017-08-05T06:17:35.470189677Z stdout: "host": "https",
   2017-08-05T06:17:35.47019376Z  stdout: "port": 443
   2017-08-05T06:17:35.470198175Z stdout: },
   2017-08-05T06:17:35.470203938Z stdout: "error": {
   2017-08-05T06:17:35.470208061Z stdout: "code": "ENOTFOUND",
   2017-08-05T06:17:35.470212246Z stdout: "errno": "ENOTFOUND",
   2017-08-05T06:17:35.470216439Z stdout: "syscall": "getaddrinfo",
   2017-08-05T06:17:35.470220611Z stdout: "hostname": "https",
   2017-08-05T06:17:35.470226979Z stdout: "host": "https",
   2017-08-05T06:17:35.470236839Z stdout: "port": 443
   2017-08-05T06:17:35.470241158Z stdout: },
   2017-08-05T06:17:35.470273276Z stdout: "options": {
   2017-08-05T06:17:35.470277356Z stdout: "method": "PUT",
   2017-08-05T06:17:35.470291858Z stdout: "url": 
"https://https://localhost:32519/api/v1/web/whisk.system/messagingWeb/messageHubFeedWeb.http;,
   2017-08-05T06:17:35.470297895Z stdout: "rejectUnauthorized": false,
   2017-08-05T06:17:35.470302195Z stdout: "json": true,
   2017-08-05T06:17:35.470306305Z stdout: "body": {
   2017-08-05T06:17:35.470320764Z stdout: "authKey": 
"789c46b1-71f6-4ed5-8c54-816aa4f8c502:abczO3xZCLrMN6v2BKK1dXYFpXlPkccOFqm12CdAsMgRU4VrNZ9lyGVCGuMDGIwP",
   2017-08-05T06:17:35.47033109Z  stdout: "topic": "mytopic",
   2017-08-05T06:17:35.470335409Z stdout: "triggerName": 
"/whisk.system/MyMessageHubTrigger"
   2017-08-05T06:17:35.470339821Z stdout: },
   2017-08-05T06:17:35.470343837Z stdout: "headers": {
   2017-08-05T06:17:35.47034804Z  stdout: "Content-Type": "application/json",
   2017-08-05T06:17:35.470352288Z stdout: "Accept": "text/plain",
   2017-08-05T06:17:35.470356496Z stdout: "User-Agent": "whisk"
   2017-08-05T06:17:35.470360713Z stdout: },
   2017-08-05T06:17:35.470391133Z stdout: "simple": true,
   2017-08-05T06:17:35.47039595Z  stdout: "resolveWithFullResponse": false,
   2017-08-05T06:17:35.470400331Z stdout: "transform2xxOnly": false
   2017-08-05T06:17:35.470404667Z stdout: }
   2017-08-05T06:17:35.470408642Z stdout: }
   
   - wsk -i activation logs faa436652b33430a963096897d5abe5a
   2017-08-05T06:17:36.158335344Z stdout: Error deleting trigger: {
   2017-08-05T06:17:36.158400819Z stdout: "name": "RequestError",
   2017-08-05T06:17:36.158409838Z stdout: "message": "Error: getaddrinfo 
ENOTFOUND https https:443",
   2017-08-05T06:17:36.158414926Z stdout: "cause": {
   2017-08-05T06:17:36.158419299Z stdout: "code": "ENOTFOUND",
   2017-08-05T06:17:36.158423583Z stdout: "errno": "ENOTFOUND",
   2017-08-05T06:17:36.158427929Z stdout: "syscall": "getaddrinfo",
   2017-08-05T06:17:36.15843222Z  stdout: "hostname": "https",
   2017-08-05T06:17:36.158439866Z stdout: "host": "https",
   2017-08-05T06:17:36.158446166Z stdout: "port": 443
   2017-08-05T06:17:36.158539889Z stdout: },
   2017-08-05T06:17:36.158546657Z stdout: "error": {
   2017-08-05T06:17:36.158559109Z stdout: "code": "ENOTFOUND",
   2017-08-05T06:17:36.15856813Z  stdout: "errno": "ENOTFOUND",
   2017-08-05T06:17:36.158582766Z stdout: "syscall": "getaddrinfo",
   2017-08-05T06:17:36.15859823Z  stdout: "hostname": "https",
   2017-08-05T06:17:36.158602383Z stdout: "host": "https",
   2017-08-05T06:17:36.15860658Z  stdout: "port": 443
   2017-08-05T06:17:36.158610748Z stdout: },
   2017-08-05T06:17:36.158614621Z stdout: "options": {
   2017-08-05T06:17:36.15861871Z  stdout: "method": "DELETE",
   2017-08-05T06:17:36.158627156Z stdout: "url": 
"https://https://localhost:32519/api/v1/web/whisk.system/messagingWeb/messageHubFeedWeb.http;,
   2017-08-05T06:17:36.158633653Z stdout: "rejectUnauthorized": false,
   2017-08-05T06:17:36.158637924Z stdout: "json": true,
   2017-08-05T06:17:36.158642076Z stdout: "body": {
   2017-08-05T06:17:36.158646974Z stdout: "authKey": 
"789c46b1-71f6-4ed5-8c54-816aa4f8c502:abczO3xZCLrMN6v2BKK1dXYFpXlPkccOFqm12CdAsMgRU4VrNZ9lyGVCGuMDGIwP",
   2017-08-05T06:17:36.158651574Z stdout: "topic": "mytopic",
   2017-08-05T06:17:36.158655786Z stdout: "triggerName": 
"/whisk.system/MyMessageHubTrigger"
   2017-08-05T06:17:36.158660277Z stdout: },
   2017-08-05T06:17:36.158664227Z stdout: "headers": {
   2017-08-05T06:17:36.158668377Z stdout: "Content-Type": "application/json",

[GitHub] zhy989 commented on issue #210: How to use message feed

2017-08-05 Thread git

zhy989 commented on issue #210: How to use message feed
URL: 
https://github.com/apache/incubator-openwhisk-package-kafka/issues/210#issuecomment-320416392
 
 
   - wsk -i activation logs b898ea7d32aa438a9e5bd697feaf8fe9
   2017-08-05T06:17:35.470076218Z stdout: Error creating trigger: {
   2017-08-05T06:17:35.470155869Z stdout: "name": "RequestError",
   2017-08-05T06:17:35.470163159Z stdout: "message": "Error: getaddrinfo 
ENOTFOUND https https:443",
   2017-08-05T06:17:35.470168151Z stdout: "cause": {
   2017-08-05T06:17:35.470172346Z stdout: "code": "ENOTFOUND",
   2017-08-05T06:17:35.470176705Z stdout: "errno": "ENOTFOUND",
   2017-08-05T06:17:35.470181028Z stdout: "syscall": "getaddrinfo",
   2017-08-05T06:17:35.470185235Z stdout: "hostname": "https",
   2017-08-05T06:17:35.470189677Z stdout: "host": "https",
   2017-08-05T06:17:35.47019376Z  stdout: "port": 443
   2017-08-05T06:17:35.470198175Z stdout: },
   2017-08-05T06:17:35.470203938Z stdout: "error": {
   2017-08-05T06:17:35.470208061Z stdout: "code": "ENOTFOUND",
   2017-08-05T06:17:35.470212246Z stdout: "errno": "ENOTFOUND",
   2017-08-05T06:17:35.470216439Z stdout: "syscall": "getaddrinfo",
   2017-08-05T06:17:35.470220611Z stdout: "hostname": "https",
   2017-08-05T06:17:35.470226979Z stdout: "host": "https",
   2017-08-05T06:17:35.470236839Z stdout: "port": 443
   2017-08-05T06:17:35.470241158Z stdout: },
   2017-08-05T06:17:35.470273276Z stdout: "options": {
   2017-08-05T06:17:35.470277356Z stdout: "method": "PUT",
   2017-08-05T06:17:35.470291858Z stdout: "url": 
"https://https://localhost:32519/api/v1/web/whisk.system/messagingWeb/messageHubFeedWeb.http;,
   2017-08-05T06:17:35.470297895Z stdout: "rejectUnauthorized": false,
   2017-08-05T06:17:35.470302195Z stdout: "json": true,
   2017-08-05T06:17:35.470306305Z stdout: "body": {
   2017-08-05T06:17:35.470320764Z stdout: "authKey": 
"789c46b1-71f6-4ed5-8c54-816aa4f8c502:abczO3xZCLrMN6v2BKK1dXYFpXlPkccOFqm12CdAsMgRU4VrNZ9lyGVCGuMDGIwP",
   2017-08-05T06:17:35.47033109Z  stdout: "topic": "mytopic",
   2017-08-05T06:17:35.470335409Z stdout: "triggerName": 
"/whisk.system/MyMessageHubTrigger"
   2017-08-05T06:17:35.470339821Z stdout: },
   2017-08-05T06:17:35.470343837Z stdout: "headers": {
   2017-08-05T06:17:35.47034804Z  stdout: "Content-Type": "application/json",
   2017-08-05T06:17:35.470352288Z stdout: "Accept": "text/plain",
   2017-08-05T06:17:35.470356496Z stdout: "User-Agent": "whisk"
   2017-08-05T06:17:35.470360713Z stdout: },
   2017-08-05T06:17:35.470391133Z stdout: "simple": true,
   2017-08-05T06:17:35.47039595Z  stdout: "resolveWithFullResponse": false,
   2017-08-05T06:17:35.470400331Z stdout: "transform2xxOnly": false
   2017-08-05T06:17:35.470404667Z stdout: }
   2017-08-05T06:17:35.470408642Z stdout: }
   
   - wsk -i activation logs faa436652b33430a963096897d5abe5a
   2017-08-05T06:17:36.158335344Z stdout: Error deleting trigger: {
   2017-08-05T06:17:36.158400819Z stdout: "name": "RequestError",
   2017-08-05T06:17:36.158409838Z stdout: "message": "Error: getaddrinfo 
ENOTFOUND https https:443",
   2017-08-05T06:17:36.158414926Z stdout: "cause": {
   2017-08-05T06:17:36.158419299Z stdout: "code": "ENOTFOUND",
   2017-08-05T06:17:36.158423583Z stdout: "errno": "ENOTFOUND",
   2017-08-05T06:17:36.158427929Z stdout: "syscall": "getaddrinfo",
   2017-08-05T06:17:36.15843222Z  stdout: "hostname": "https",
   2017-08-05T06:17:36.158439866Z stdout: "host": "https",
   2017-08-05T06:17:36.158446166Z stdout: "port": 443
   2017-08-05T06:17:36.158539889Z stdout: },
   2017-08-05T06:17:36.158546657Z stdout: "error": {
   2017-08-05T06:17:36.158559109Z stdout: "code": "ENOTFOUND",
   2017-08-05T06:17:36.15856813Z  stdout: "errno": "ENOTFOUND",
   2017-08-05T06:17:36.158582766Z stdout: "syscall": "getaddrinfo",
   2017-08-05T06:17:36.15859823Z  stdout: "hostname": "https",
   2017-08-05T06:17:36.158602383Z stdout: "host": "https",
   2017-08-05T06:17:36.15860658Z  stdout: "port": 443
   2017-08-05T06:17:36.158610748Z stdout: },
   2017-08-05T06:17:36.158614621Z stdout: "options": {
   2017-08-05T06:17:36.15861871Z  stdout: "method": "DELETE",
   2017-08-05T06:17:36.158627156Z stdout: "url": 
"https://https://localhost:32519/api/v1/web/whisk.system/messagingWeb/messageHubFeedWeb.http;,
   2017-08-05T06:17:36.158633653Z stdout: "rejectUnauthorized": false,
   2017-08-05T06:17:36.158637924Z stdout: "json": true,
   2017-08-05T06:17:36.158642076Z stdout: "body": {
   2017-08-05T06:17:36.158646974Z stdout: "authKey": 
"789c46b1-71f6-4ed5-8c54-816aa4f8c502:abczO3xZCLrMN6v2BKK1dXYFpXlPkccOFqm12CdAsMgRU4VrNZ9lyGVCGuMDGIwP",
   2017-08-05T06:17:36.158651574Z stdout: "topic": "mytopic",
   2017-08-05T06:17:36.158655786Z stdout: "triggerName": 
"/whisk.system/MyMessageHubTrigger"
   2017-08-05T06:17:36.158660277Z stdout: },
   2017-08-05T06:17:36.158664227Z stdout: "headers": {
   2017-08-05T06:17:36.158668377Z stdout: "Content-Type": "application/json",
   2017-08-05T06:17:36.158672635Z

[GitHub] zhy989 commented on issue #210: How to use message feed

2017-08-04 Thread git

zhy989 commented on issue #210: How to use message feed
URL: 
https://github.com/apache/incubator-openwhisk-package-kafka/issues/210#issuecomment-320191488
 
 
   - wsk trigger create MyMessageHubTrigger -f 
/whisk.system/messaging/messageHubFeed -p topic mytopic -i
   ok: invoked /whisk.system/messaging/messageHubFeed with id 
69c08183c6c74241ba96c4ff6512f549
   {
   "activationId": "69c08183c6c74241ba96c4ff6512f549",
   "annotations": [
   {
   "key": "limits",
   "value": {
   "logs": 10,
   "memory": 256,
   "timeout": 6
   }
   },
   {
   "key": "path",
   "value": "whisk.system/messaging/messageHubFeed"
   }
   ],
   "duration": 2354,
   "end": 1501835456247,
   "logs": [],
   "name": "messageHubFeed",
   "namespace": "whisk.system",
   "publish": false,
   "response": {
   "result": {
   "error": {}
   },
   "status": "application error",
   "success": false
   },
   "start": 1501835453893,
   "subject": "whisk.system",
   "version": "0.0.1"
   }
   ok: invoked /whisk.system/messaging/messageHubFeed with id 
dcb2451ba38848dd98e1d3edfce3e9aa
   {
   "activationId": "dcb2451ba38848dd98e1d3edfce3e9aa",
   "annotations": [
   {
   "key": "limits",
   "value": {
   "logs": 10,
   "memory": 256,
   "timeout": 6
   }
   },
   {
   "key": "path",
   "value": "whisk.system/messaging/messageHubFeed"
   }
   ],
   "duration": 17,
   "end": 1501835456401,
   "logs": [],
   "name": "messageHubFeed",
   "namespace": "whisk.system",
   "publish": false,
   "response": {
   "result": {
   "error": {}
   },
   "status": "application error",
   "success": false
   },
   "start": 1501835456384,
   "subject": "whisk.system",
   "version": "0.0.1"
   }
   **ok: deleted trigger MyMessageHubTrigger**
   Run 'wsk --help' for usage.
   
   I can not create trigger  MyMessageHubTrigger successfully.
   
   
 

This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


With regards,
Apache Git Services

[GitHub] zhy989 commented on issue #210: How to use message feed

[GitHub] zhy989 commented on issue #210: How to use message feed

[GitHub] zhy989 commented on issue #210: How to use message feed

[GitHub] zhy989 commented on issue #210: How to use message feed

[GitHub] zhy989 commented on issue #210: How to use message feed

[GitHub] zhy989 commented on issue #210: How to use message feed

[GitHub] zhy989 commented on issue #210: How to use message feed

[GitHub] zhy989 commented on issue #210: How to use message feed

[GitHub] zhy989 commented on issue #210: How to use message feed

[GitHub] zhy989 commented on issue #210: How to use message feed

[GitHub] zhy989 commented on issue #210: How to use message feed

[GitHub] zhy989 commented on issue #210: How to use message feed

[GitHub] zhy989 commented on issue #210: How to use message feed

[GitHub] zhy989 commented on issue #210: How to use message feed

[GitHub] zhy989 commented on issue #210: How to use message feed

[GitHub] zhy989 commented on issue #210: How to use message feed

[GitHub] zhy989 commented on issue #210: How to use message feed

[GitHub] zhy989 commented on issue #210: How to use message feed

18 matches

Site Navigation

Mail list logo

Footer information